public class DataSetTable<T> extends FlinkTable<T>
Constructor and Description |
---|
DataSetTable(DataSet<T> dataSet,
int[] fieldIndexes,
String[] fieldNames,
FlinkStatistic statistic) |
Modifier and Type | Method and Description |
---|---|
DataSet<T> |
dataSet() |
int[] |
fieldIndexes() |
String[] |
fieldNames() |
static TypeInformation<?>[] |
fieldTypes() |
static org.apache.calcite.schema.Schema.TableType |
getJdbcTableType() |
static org.apache.calcite.rel.type.RelDataType |
getRowType(org.apache.calcite.rel.type.RelDataTypeFactory typeFactory) |
static org.apache.calcite.schema.Statistic |
getStatistic() |
FlinkStatistic |
statistic() |
static TypeInformation<T> |
typeInfo() |
fieldTypes, getRowType, getStatistic, typeInfo
public DataSetTable(DataSet<T> dataSet, int[] fieldIndexes, String[] fieldNames, FlinkStatistic statistic)
public static org.apache.calcite.schema.Schema.TableType getJdbcTableType()
public static TypeInformation<T> typeInfo()
public static TypeInformation<?>[] fieldTypes()
public static org.apache.calcite.rel.type.RelDataType getRowType(org.apache.calcite.rel.type.RelDataTypeFactory typeFactory)
public static org.apache.calcite.schema.Statistic getStatistic()
public int[] fieldIndexes()
fieldIndexes
in class FlinkTable<T>
public String[] fieldNames()
fieldNames
in class FlinkTable<T>
public FlinkStatistic statistic()
statistic
in class FlinkTable<T>
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.