public abstract class FlinkTable<T>
extends org.apache.calcite.schema.impl.AbstractTable
Constructor and Description |
---|
FlinkTable(TypeInformation<T> typeInfo,
int[] fieldIndexes,
String[] fieldNames,
FlinkStatistic statistic) |
Modifier and Type | Method and Description |
---|---|
int[] |
fieldIndexes() |
String[] |
fieldNames() |
TypeInformation<?>[] |
fieldTypes() |
org.apache.calcite.rel.type.RelDataType |
getRowType(org.apache.calcite.rel.type.RelDataTypeFactory typeFactory) |
org.apache.calcite.schema.Statistic |
getStatistic()
Returns statistics of current table
|
FlinkStatistic |
statistic() |
TypeInformation<T> |
typeInfo() |
public FlinkTable(TypeInformation<T> typeInfo, int[] fieldIndexes, String[] fieldNames, FlinkStatistic statistic)
public TypeInformation<T> typeInfo()
public int[] fieldIndexes()
public String[] fieldNames()
public FlinkStatistic statistic()
public TypeInformation<?>[] fieldTypes()
public org.apache.calcite.rel.type.RelDataType getRowType(org.apache.calcite.rel.type.RelDataTypeFactory typeFactory)
public org.apache.calcite.schema.Statistic getStatistic()
getStatistic
in interface org.apache.calcite.schema.Table
getStatistic
in class org.apache.calcite.schema.impl.AbstractTable
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.