org.apache.beam.sdk.extensions.sql.impl

Class BeamTableStatistics

java.lang.Object

org.apache.beam.sdk.extensions.sql.impl.BeamTableStatistics

All Implemented Interfaces:

java.io.Serializable, org.apache.calcite.schema.Statistic

@Experimental
 @Internal
public class BeamTableStatistics
extends java.lang.Object
implements java.io.Serializable, org.apache.calcite.schema.Statistic

This class stores row count statistics.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static BeamTableStatistics	UNBOUNDED_UNKNOWN
static BeamTableStatistics	UNKNOWN

Method Summary

Modifier and Type	Method and Description
static BeamTableStatistics	createBoundedTableStatistics(java.lang.Double rowCount)
static BeamTableStatistics	createUnboundedTableStatistics(java.lang.Double rate)
java.util.List<org.apache.calcite.rel.RelCollation>	getCollations()
org.apache.calcite.rel.RelDistribution	getDistribution()
java.lang.Double	getRate()
java.util.List<org.apache.calcite.rel.RelReferentialConstraint>	getReferentialConstraints()
java.lang.Double	getRowCount()
boolean	isKey(org.apache.calcite.util.ImmutableBitSet columns)
boolean	isUnknown()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

UNKNOWN

public static final BeamTableStatistics UNKNOWN

UNBOUNDED_UNKNOWN

public static final BeamTableStatistics UNBOUNDED_UNKNOWN

Method Detail

createBoundedTableStatistics

public static BeamTableStatistics createBoundedTableStatistics(java.lang.Double rowCount)

createUnboundedTableStatistics

public static BeamTableStatistics createUnboundedTableStatistics(java.lang.Double rate)

getRate

public java.lang.Double getRate()

isUnknown

public boolean isUnknown()

getRowCount

public java.lang.Double getRowCount()

Specified by:

getRowCount in interface org.apache.calcite.schema.Statistic

isKey

public boolean isKey(org.apache.calcite.util.ImmutableBitSet columns)

Specified by:

isKey in interface org.apache.calcite.schema.Statistic

getReferentialConstraints

public java.util.List<org.apache.calcite.rel.RelReferentialConstraint> getReferentialConstraints()

Specified by:

getReferentialConstraints in interface org.apache.calcite.schema.Statistic

getCollations

public java.util.List<org.apache.calcite.rel.RelCollation> getCollations()

Specified by:

getCollations in interface org.apache.calcite.schema.Statistic

getDistribution

public org.apache.calcite.rel.RelDistribution getDistribution()

Specified by:

getDistribution in interface org.apache.calcite.schema.Statistic