Package org.apache.flink.table.planner.plan.nodes.hive

Class LogicalDistribution

  • All Implemented Interfaces:
    Cloneable, org.apache.calcite.plan.RelOptNode, org.apache.calcite.rel.RelNode
    public class LogicalDistribution
extends org.apache.calcite.rel.SingleRel
    LogicalDistribution is used to represent the expected distribution of the data, similar to Hive's SORT BY, DISTRIBUTE BY, and CLUSTER BY semantics.

    • Nested Class Summary

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

        org.apache.calcite.rel.RelNode.Context

    • Field Summary

      • Fields inherited from class org.apache.calcite.rel.SingleRel

        input

      • Fields inherited from class org.apache.calcite.rel.AbstractRelNode

        digest, id, rowType, traitSet

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      org.apache.calcite.rel.RelNode accept​(org.apache.calcite.rel.RelShuttle shuttle)  
      LogicalDistribution copy​(org.apache.calcite.plan.RelTraitSet traitSet, List<org.apache.calcite.rel.RelNode> inputs)  
      static LogicalDistribution create​(org.apache.calcite.rel.RelNode input, org.apache.calcite.rel.RelCollation collation, List<Integer> distKeys)  
      org.apache.calcite.rel.RelWriter explainTerms​(org.apache.calcite.rel.RelWriter pw)  
      org.apache.calcite.rel.RelCollation getCollation()  
      List<Integer> getDistKeys()  

      • Methods inherited from class org.apache.calcite.rel.SingleRel

        childrenAccept, deriveRowType, estimateRowCount, getInput, getInputs, replaceInput

      • Methods inherited from class org.apache.calcite.rel.AbstractRelNode

        accept, collectVariablesSet, collectVariablesUsed, computeSelfCost, 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 interface org.apache.calcite.rel.RelNode

        explain, fieldIsNullable

    • Method Detail

      • create

        public static LogicalDistribution create​(org.apache.calcite.rel.RelNode input,
                                         org.apache.calcite.rel.RelCollation collation,
                                         List<Integer> distKeys)

      • getCollation

        public org.apache.calcite.rel.RelCollation getCollation()

      • copy

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

      • accept

        public org.apache.calcite.rel.RelNode accept​(org.apache.calcite.rel.RelShuttle shuttle)
        Specified by:
        accept in interface org.apache.calcite.rel.RelNode
        Overrides:
        accept in class org.apache.calcite.rel.AbstractRelNode

      • explainTerms

        public org.apache.calcite.rel.RelWriter explainTerms​(org.apache.calcite.rel.RelWriter pw)
        Overrides:
        explainTerms in class org.apache.calcite.rel.SingleRel