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

类 LogicalDistribution

java.lang.Object

org.apache.calcite.rel.AbstractRelNode

org.apache.calcite.rel.SingleRel

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

所有已实现的接口:

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.

嵌套类概要

从接口继承的嵌套类/接口 org.apache.calcite.rel.RelNode

org.apache.calcite.rel.RelNode.Context

字段概要

从类继承的字段 org.apache.calcite.rel.SingleRel

input

从类继承的字段 org.apache.calcite.rel.AbstractRelNode

digest, id, rowType, traitSet

方法概要

限定符和类型	方法和说明
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()

从类继承的方法 org.apache.calcite.rel.SingleRel

childrenAccept, deriveRowType, estimateRowCount, getInput, getInputs, replaceInput

从类继承的方法 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

从类继承的方法 java.lang.Object

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

从接口继承的方法 org.apache.calcite.rel.RelNode

explain

方法详细资料

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)

指定者:

copy 在接口中 org.apache.calcite.rel.RelNode

覆盖:

copy 在类中 org.apache.calcite.rel.AbstractRelNode

accept

public org.apache.calcite.rel.RelNode accept(org.apache.calcite.rel.RelShuttle shuttle)

指定者:

accept 在接口中 org.apache.calcite.rel.RelNode

覆盖:

accept 在类中 org.apache.calcite.rel.AbstractRelNode

explainTerms

public org.apache.calcite.rel.RelWriter explainTerms(org.apache.calcite.rel.RelWriter pw)

覆盖:

explainTerms 在类中 org.apache.calcite.rel.SingleRel