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

Class RelMdNodeStats

java.lang.Object

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

All Implemented Interfaces:

org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.metadata.MetadataHandler<NodeStatsMetadata>

public class RelMdNodeStats
extends java.lang.Object
implements org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.metadata.MetadataHandler<NodeStatsMetadata>

This is the implementation of NodeStatsMetadata. Methods to estimate rate and row count for Calcite's logical nodes be implemented here.

Field Summary

Fields

Modifier and Type	Field and Description
static org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.metadata.RelMetadataProvider	SOURCE

Constructor Summary

Constructors

Constructor and Description
RelMdNodeStats()

Method Summary

Modifier and Type	Method and Description
org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.metadata.MetadataDef<NodeStatsMetadata>	getDef()
NodeStats	getNodeStats(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.RelNode rel, org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.metadata.RelMetadataQuery mq)

Methods inherited from class java.lang.Object

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

Field Detail

SOURCE

public static final org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.metadata.RelMetadataProvider SOURCE

Constructor Detail

RelMdNodeStats

public RelMdNodeStats()

Method Detail

getDef

public org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.metadata.MetadataDef<NodeStatsMetadata> getDef()

Specified by:

getDef in interface org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.metadata.MetadataHandler<NodeStatsMetadata>

getNodeStats

public NodeStats getNodeStats(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.RelNode rel,
                              org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.metadata.RelMetadataQuery mq)