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

Class BeamTableStatistics

java.lang.Object

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

All Implemented Interfaces:

Serializable, org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.Statistic

@Internal
public class BeamTableStatistics
extends Object
implements Serializable, org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.Statistic

This class stores row count statistics.

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static final BeamTableStatistics	BOUNDED_UNKNOWN
static final BeamTableStatistics	UNBOUNDED_UNKNOWN

Method Summary

Modifier and Type	Method	Description
static BeamTableStatistics	createBoundedTableStatistics(Double rowCount)
static BeamTableStatistics	createUnboundedTableStatistics(Double rate)
List<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.RelCollation>	getCollations()
org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.RelDistribution	getDistribution()
List<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.util.ImmutableBitSet>	getKeys()
Double	getRate()
List<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.RelReferentialConstraint>	getReferentialConstraints()
Double	getRowCount()
boolean	isKey(org.apache.beam.vendor.calcite.v1_28_0.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 Details

BOUNDED_UNKNOWN

public static final BeamTableStatistics BOUNDED_UNKNOWN

UNBOUNDED_UNKNOWN

public static final BeamTableStatistics UNBOUNDED_UNKNOWN

Method Details

createBoundedTableStatistics

public static BeamTableStatistics createBoundedTableStatistics(Double rowCount)

createUnboundedTableStatistics

public static BeamTableStatistics createUnboundedTableStatistics(Double rate)

getRate

public Double getRate()

isUnknown

public boolean isUnknown()

getRowCount

public Double getRowCount()

Specified by:

getRowCount in interface org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.Statistic

isKey

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

Specified by:

isKey in interface org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.Statistic

getKeys

public List<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.util.ImmutableBitSet> getKeys()

Specified by:

getKeys in interface org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.Statistic

getReferentialConstraints

public List<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.RelReferentialConstraint> getReferentialConstraints()

Specified by:

getReferentialConstraints in interface org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.Statistic

getCollations

public List<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.RelCollation> getCollations()

Specified by:

getCollations in interface org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.Statistic

getDistribution

public org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.RelDistribution getDistribution()

Specified by:

getDistribution in interface org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.Statistic