public class FlinkStatistic extends Object implements org.apache.calcite.schema.Statistic
FlinkTable
.
param: tableStats The table statistics.
Constructor and Description |
---|
FlinkStatistic(scala.Option<TableStats> tableStats) |
Modifier and Type | Method and Description |
---|---|
List<org.apache.calcite.rel.RelCollation> |
getCollations() |
ColumnStats |
getColumnStats(String columnName)
Returns the stats of the specified the column.
|
org.apache.calcite.rel.RelDistribution |
getDistribution() |
Double |
getRowCount()
Returns the number of rows of the table.
|
TableStats |
getTableStats()
Returns the table statistics.
|
boolean |
isKey(org.apache.calcite.util.ImmutableBitSet columns) |
static FlinkStatistic |
of(TableStats tableStats)
Returns a FlinkStatistic with given table statistics.
|
static FlinkStatistic |
UNKNOWN()
Represents a FlinkStatistic that knows nothing about a table
|
public FlinkStatistic(scala.Option<TableStats> tableStats)
public static FlinkStatistic UNKNOWN()
public static FlinkStatistic of(TableStats tableStats)
tableStats
- The table statistics.public TableStats getTableStats()
public ColumnStats getColumnStats(String columnName)
columnName
- The name of the column for which the stats are requested.public Double getRowCount()
getRowCount
in interface org.apache.calcite.schema.Statistic
public List<org.apache.calcite.rel.RelCollation> getCollations()
getCollations
in interface org.apache.calcite.schema.Statistic
public boolean isKey(org.apache.calcite.util.ImmutableBitSet columns)
isKey
in interface org.apache.calcite.schema.Statistic
public org.apache.calcite.rel.RelDistribution getDistribution()
getDistribution
in interface org.apache.calcite.schema.Statistic
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.