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

Class LogicalDistribution

java.lang.Object

org.apache.calcite.rel.AbstractRelNode

org.apache.calcite.rel.SingleRel

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

All Implemented Interfaces:

Cloneable, org.apache.calcite.plan.RelOptNode, org.apache.calcite.rel.RelNode

public class LogicalDistribution
extends org.apache.calcite.rel.SingleRel

Copied from Flink code base.

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

Modifier and Type	Method and 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 class java.lang.Object

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

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)

getDistKeys

public List<Integer> getDistKeys()

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