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

Class BeamEnumerableConverter

  • All Implemented Interfaces:
    java.lang.Cloneable, org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.adapter.enumerable.EnumerableRel, org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.plan.RelOptNode, org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.convert.Converter, org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.PhysicalNode, org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.RelNode
    public class BeamEnumerableConverter
extends org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.convert.ConverterImpl
implements org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.adapter.enumerable.EnumerableRel
    BeamRelNode to replace a Enumerable node.

    • Nested Class Summary

      • Nested classes/interfaces inherited from interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.adapter.enumerable.EnumerableRel

        org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.adapter.enumerable.EnumerableRel.Prefer, org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.adapter.enumerable.EnumerableRel.Result

      • Nested classes/interfaces inherited from interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.RelNode

        org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.RelNode.Context

    • Field Summary

      • Fields inherited from class org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.convert.ConverterImpl

        inTraits, traitDef

      • Fields inherited from class org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.SingleRel

        input

      • Fields inherited from class org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.AbstractRelNode

        digest, id, rowType, traitSet

    • Constructor Summary

      Constructors 
      Constructor Description
      BeamEnumerableConverter​(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.plan.RelOptCluster cluster, org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.plan.RelTraitSet traits, org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.RelNode input)  

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.plan.RelOptCost computeSelfCost​(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.plan.RelOptPlanner planner, org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.metadata.RelMetadataQuery mq)  
      org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.RelNode copy​(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.plan.RelTraitSet traitSet, java.util.List<org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.RelNode> inputs)  
      static org.apache.beam.sdk.options.PipelineOptions createPipelineOptions​(java.util.Map<java.lang.String,​java.lang.String> map)  
      org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.adapter.enumerable.EnumerableRel.Result implement​(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.adapter.enumerable.EnumerableRelImplementor implementor, org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.adapter.enumerable.EnumerableRel.Prefer prefer)  
      static org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.linq4j.Enumerable<java.lang.Object> toEnumerable​(BeamRelNode node)  
      static java.util.List<org.apache.beam.sdk.values.Row> toRowList​(BeamRelNode node)  
      static java.util.List<org.apache.beam.sdk.values.Row> toRowList​(BeamRelNode node, java.util.Map<java.lang.String,​java.lang.String> otherOptions)  

      • Methods inherited from class org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.convert.ConverterImpl

        cannotImplement, getInputTraits, getTraitDef

      • Methods inherited from class org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.SingleRel

        childrenAccept, deriveRowType, estimateRowCount, explainTerms, getInput, getInputs, replaceInput

      • Methods inherited from class org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.AbstractRelNode

        accept, accept, collectVariablesSet, collectVariablesUsed, deepEquals, deepHashCode, equals, explain, getCluster, getConvention, getCorrelVariable, getDescription, getDigest, getExpectedInputRowType, getId, getInput, getRelDigest, getRelTypeName, getRowType, getTable, getTraitSet, getVariablesSet, hashCode, isEnforcer, isValid, metadata, onRegister, recomputeDigest, register, sole, toString

      • Methods inherited from class java.lang.Object

        clone, finalize, getClass, notify, notifyAll, wait, wait, wait

      • Methods inherited from interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.convert.Converter

        getInput

      • Methods inherited from interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.adapter.enumerable.EnumerableRel

        deriveTraits, getDeriveMode, passThroughTraits

      • Methods inherited from interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.PhysicalNode

        derive, derive, passThrough

      • Methods inherited from interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.RelNode

        accept, accept, childrenAccept, collectVariablesSet, collectVariablesUsed, deepEquals, deepHashCode, estimateRowCount, explain, explain, fieldIsNullable, getConvention, getCorrelVariable, getDigest, getExpectedInputRowType, getInput, getInputs, getRelDigest, getRelTypeName, getRowType, getTable, getVariablesSet, isEnforcer, isValid, metadata, onRegister, recomputeDigest, register, replaceInput, stripped

      • Methods inherited from interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.plan.RelOptNode

        getCluster, getDescription, getId, getTraitSet

    • Constructor Detail

      • BeamEnumerableConverter

        public BeamEnumerableConverter​(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.plan.RelOptCluster cluster,
                               org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.plan.RelTraitSet traits,
                               org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.RelNode input)

    • Method Detail

      • copy

        public org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.RelNode copy​(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.plan.RelTraitSet traitSet,
                                                                                  java.util.List<org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.RelNode> inputs)
        Specified by:
        copy in interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.RelNode
        Overrides:
        copy in class org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.AbstractRelNode

      • computeSelfCost

        public org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.plan.RelOptCost computeSelfCost​(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.plan.RelOptPlanner planner,
                                                                                                 org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.metadata.RelMetadataQuery mq)
        Specified by:
        computeSelfCost in interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.RelNode
        Overrides:
        computeSelfCost in class org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.convert.ConverterImpl

      • implement

        public org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.adapter.enumerable.EnumerableRel.Result implement​(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.adapter.enumerable.EnumerableRelImplementor implementor,
                                                                                                                   org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.adapter.enumerable.EnumerableRel.Prefer prefer)
        Specified by:
        implement in interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.adapter.enumerable.EnumerableRel

      • toEnumerable

        public static org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.linq4j.Enumerable<java.lang.Object> toEnumerable​(BeamRelNode node)

      • toRowList

        public static java.util.List<org.apache.beam.sdk.values.Row> toRowList​(BeamRelNode node)

      • toRowList

        public static java.util.List<org.apache.beam.sdk.values.Row> toRowList​(BeamRelNode node,
                                                                       java.util.Map<java.lang.String,​java.lang.String> otherOptions)

      • createPipelineOptions

        public static org.apache.beam.sdk.options.PipelineOptions createPipelineOptions​(java.util.Map<java.lang.String,​java.lang.String> map)