public class DataSetTable<T> extends FlinkTable<T>
Constructor and Description |
---|
DataSetTable(DataSet<T> dataSet,
int[] fieldIndexes,
String[] fieldNames) |
Modifier and Type | Method and Description |
---|---|
DataSet<T> |
dataSet() |
int[] |
fieldIndexes() |
String[] |
fieldNames() |
org.apache.calcite.schema.Statistic |
getStatistic() |
fieldTypes, getRowType, typeInfo
public int[] fieldIndexes()
fieldIndexes
in class FlinkTable<T>
public String[] fieldNames()
fieldNames
in class FlinkTable<T>
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–2017 The Apache Software Foundation. All rights reserved.