Package | Description |
---|---|
org.apache.flink.table.plan.schema | |
org.apache.flink.table.plan.stats |
Modifier and Type | Method and Description |
---|---|
FlinkStatistic |
DataSetTable.statistic() |
FlinkStatistic |
StreamTableSourceTable.statistic() |
FlinkStatistic |
FlinkTable.statistic() |
FlinkStatistic |
TableSourceTable.statistic() |
FlinkStatistic |
DataStreamTable.statistic() |
Constructor and Description |
---|
DataSetTable(DataSet<T> dataSet,
int[] fieldIndexes,
String[] fieldNames,
FlinkStatistic statistic) |
DataStreamTable(DataStream<T> dataStream,
int[] fieldIndexes,
String[] fieldNames,
scala.Option<scala.Tuple2<Object,String>> rowtime,
scala.Option<scala.Tuple2<Object,String>> proctime,
FlinkStatistic statistic) |
FlinkTable(TypeInformation<T> typeInfo,
int[] fieldIndexes,
String[] fieldNames,
FlinkStatistic statistic) |
StreamTableSourceTable(TableSource<T> tableSource,
FlinkStatistic statistic) |
TableSourceTable(TableSource<T> tableSource,
FlinkStatistic statistic) |
Modifier and Type | Method and Description |
---|---|
FlinkStatistic |
FlinkStatistic$.of(TableStats tableStats)
Returns a FlinkStatistic with given table statistics.
|
static FlinkStatistic |
FlinkStatistic.of(TableStats tableStats)
Returns a FlinkStatistic with given table statistics.
|
FlinkStatistic |
FlinkStatistic$.UNKNOWN()
Represents a FlinkStatistic that knows nothing about a table
|
static FlinkStatistic |
FlinkStatistic.UNKNOWN()
Represents a FlinkStatistic that knows nothing about a table
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.