public class BeamEnumerableConverter
extends org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.convert.ConverterImpl
implements org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.adapter.enumerable.EnumerableRel
Enumerable
node.org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.adapter.enumerable.EnumerableRel.Prefer, org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.adapter.enumerable.EnumerableRel.Result
inTraits, traitDef
input
Constructor and Description |
---|
BeamEnumerableConverter(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.plan.RelOptCluster cluster,
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.plan.RelTraitSet traits,
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.RelNode input) |
Modifier and Type | Method and Description |
---|---|
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.plan.RelOptCost |
computeSelfCost(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.plan.RelOptPlanner planner,
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.metadata.RelMetadataQuery mq) |
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.RelNode |
copy(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.plan.RelTraitSet traitSet,
java.util.List<org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.RelNode> inputs) |
static PipelineOptions |
createPipelineOptions(java.util.Map<java.lang.String,java.lang.String> map) |
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.adapter.enumerable.EnumerableRel.Result |
implement(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.adapter.enumerable.EnumerableRelImplementor implementor,
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.adapter.enumerable.EnumerableRel.Prefer prefer) |
static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.linq4j.Enumerable<java.lang.Object> |
toEnumerable(BeamRelNode node) |
static java.util.List<Row> |
toRowList(BeamRelNode node) |
cannotImplement, getInputTraits, getTraitDef
childrenAccept, deriveRowType, estimateRowCount, explainTerms, getInput, getInputs, replaceInput
accept, accept, collectVariablesSet, collectVariablesUsed, computeDigest, computeSelfCost, explain, getChildExps, getCluster, getCollationList, getConvention, getCorrelVariable, getDescription, getDigest, getExpectedInputRowType, getId, getInput, getQuery, getRelTypeName, getRows, getRowType, getTable, getTraitSet, getVariablesSet, getVariablesStopped, isDistinct, isKey, isValid, isValid, metadata, onRegister, recomputeDigest, register, sole, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
accept, accept, childrenAccept, collectVariablesSet, collectVariablesUsed, computeSelfCost, estimateRowCount, explain, getChildExps, getCollationList, getConvention, getCorrelVariable, getExpectedInputRowType, getInput, getInputs, getQuery, getRelTypeName, getRows, getRowType, getTable, getVariablesSet, getVariablesStopped, isDistinct, isKey, isValid, isValid, metadata, onRegister, recomputeDigest, register, replaceInput
public BeamEnumerableConverter(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.plan.RelOptCluster cluster, org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.plan.RelTraitSet traits, org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.RelNode input)
public org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.RelNode copy(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.plan.RelTraitSet traitSet, java.util.List<org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.RelNode> inputs)
copy
in interface org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.RelNode
copy
in class org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.AbstractRelNode
public org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.plan.RelOptCost computeSelfCost(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.plan.RelOptPlanner planner, org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.metadata.RelMetadataQuery mq)
computeSelfCost
in interface org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.RelNode
computeSelfCost
in class org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.convert.ConverterImpl
public org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.adapter.enumerable.EnumerableRel.Result implement(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.adapter.enumerable.EnumerableRelImplementor implementor, org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.adapter.enumerable.EnumerableRel.Prefer prefer)
implement
in interface org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.adapter.enumerable.EnumerableRel
public static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.linq4j.Enumerable<java.lang.Object> toEnumerable(BeamRelNode node)
public static java.util.List<Row> toRowList(BeamRelNode node)
public static PipelineOptions createPipelineOptions(java.util.Map<java.lang.String,java.lang.String> map)