org.apache.drill.exec.planner.physical

Class LateralJoinPrel

java.lang.Object

org.apache.calcite.rel.AbstractRelNode

org.apache.calcite.rel.BiRel

org.apache.calcite.rel.core.Correlate

org.apache.drill.exec.planner.common.DrillLateralJoinRelBase

org.apache.drill.exec.planner.physical.LateralJoinPrel

All Implemented Interfaces:

Cloneable, Iterable<Prel>, org.apache.calcite.plan.RelOptNode, org.apache.calcite.rel.RelNode, DrillRelNode, Prel

public class LateralJoinPrel
extends DrillLateralJoinRelBase
implements Prel

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.drill.exec.planner.common.DrillLateralJoinRelBase

excludeCorrelateColumn, IMPLICIT_COLUMN

Fields inherited from class org.apache.calcite.rel.core.Correlate

correlationId, joinType, requiredColumns

Fields inherited from class org.apache.calcite.rel.BiRel

left, right

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

digest, id, rowType, traitSet

Fields inherited from interface org.apache.drill.exec.planner.physical.Prel

DRILL_PHYSICAL

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	LateralJoinPrel(org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.plan.RelTraitSet traits, org.apache.calcite.rel.RelNode left, org.apache.calcite.rel.RelNode right, boolean excludeCorrelateCol, org.apache.calcite.rel.core.CorrelationId correlationId, org.apache.calcite.util.ImmutableBitSet requiredColumns, org.apache.calcite.rel.core.JoinRelType semiJoinType)

Method Summary

Modifier and Type	Method and Description
<T,X,E extends Throwable> T	accept(PrelVisitor<T,X,E> visitor, X value)
org.apache.calcite.rel.core.Correlate	copy(org.apache.calcite.plan.RelTraitSet traitSet, org.apache.calcite.rel.RelNode left, org.apache.calcite.rel.RelNode right, org.apache.calcite.rel.core.CorrelationId correlationId, org.apache.calcite.util.ImmutableBitSet requiredColumns, org.apache.calcite.rel.core.JoinRelType joinType)
org.apache.calcite.rel.RelWriter	explainTerms(org.apache.calcite.rel.RelWriter pw)
BatchSchema.SelectionVectorMode	getEncoding() A Prel's own SelectionVector mode - i.e whether it generates an SV2, SV4 or None
org.apache.calcite.rel.RelNode	getLateralInput(int ordinal, org.apache.calcite.rel.RelNode input) Check to make sure that the fields of the inputs are the same as the output field names.
PhysicalOperator	getPhysicalOperator(PhysicalPlanCreator creator)
BatchSchema.SelectionVectorMode[]	getSupportedEncodings() Supported 'encodings' of a Prel indicates what are the acceptable modes of SelectionVector of its child Prel
Iterator<Prel>	iterator()
boolean	needsFinalColumnReordering()

Methods inherited from class org.apache.drill.exec.planner.common.DrillLateralJoinRelBase

computeSelfCost, constructRowType, deriveRowType, estimateRowCount, getInputSize, removeImplicitField

Methods inherited from class org.apache.calcite.rel.core.Correlate

copy, getCorrelationId, getCorrelVariable, getJoinType, getRequiredColumns, getVariablesSet, isValid

Methods inherited from class org.apache.calcite.rel.BiRel

childrenAccept, getInputs, getLeft, getRight, replaceInput

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

accept, accept, collectVariablesSet, collectVariablesUsed, computeDigest, computeSelfCost, equals, explain, getChildExps, getCluster, getCollationList, getConvention, getDescription, getDigest, getExpectedInputRowType, getId, getInput, getQuery, getRelTypeName, getRows, getRowType, getTable, getTraitSet, getVariablesStopped, hashCode, isDistinct, isKey, 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.drill.exec.planner.physical.Prel

prepareForLateralUnnestPipeline

Methods inherited from interface org.apache.calcite.rel.RelNode

accept, accept, childrenAccept, collectVariablesSet, collectVariablesUsed, computeSelfCost, computeSelfCost, copy, 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

Methods inherited from interface org.apache.calcite.plan.RelOptNode

getCluster, getDescription, getDigest, getId, getTraitSet

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

LateralJoinPrel

protected LateralJoinPrel(org.apache.calcite.plan.RelOptCluster cluster,
                          org.apache.calcite.plan.RelTraitSet traits,
                          org.apache.calcite.rel.RelNode left,
                          org.apache.calcite.rel.RelNode right,
                          boolean excludeCorrelateCol,
                          org.apache.calcite.rel.core.CorrelationId correlationId,
                          org.apache.calcite.util.ImmutableBitSet requiredColumns,
                          org.apache.calcite.rel.core.JoinRelType semiJoinType)

Method Detail

copy

public org.apache.calcite.rel.core.Correlate copy(org.apache.calcite.plan.RelTraitSet traitSet,
                                                  org.apache.calcite.rel.RelNode left,
                                                  org.apache.calcite.rel.RelNode right,
                                                  org.apache.calcite.rel.core.CorrelationId correlationId,
                                                  org.apache.calcite.util.ImmutableBitSet requiredColumns,
                                                  org.apache.calcite.rel.core.JoinRelType joinType)

Specified by:

copy in class org.apache.calcite.rel.core.Correlate

getPhysicalOperator

public PhysicalOperator getPhysicalOperator(PhysicalPlanCreator creator)
                                     throws IOException

Specified by:

getPhysicalOperator in interface Prel

Throws:

IOException

getLateralInput

public org.apache.calcite.rel.RelNode getLateralInput(int ordinal,
                                                      org.apache.calcite.rel.RelNode input)

Check to make sure that the fields of the inputs are the same as the output field names. If not, insert a project renaming them.

explainTerms

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

Overrides:

explainTerms in class org.apache.calcite.rel.core.Correlate

accept

public <T,X,E extends Throwable> T accept(PrelVisitor<T,X,E> visitor,
                                          X value)
                                   throws E extends Throwable

Specified by:

accept in interface Prel

Throws:

E extends Throwable

iterator

public Iterator<Prel> iterator()

Specified by:

iterator in interface Iterable<Prel>

needsFinalColumnReordering

public boolean needsFinalColumnReordering()

Specified by:

needsFinalColumnReordering in interface Prel

getSupportedEncodings

public BatchSchema.SelectionVectorMode[] getSupportedEncodings()

Description copied from interface: Prel

Supported 'encodings' of a Prel indicates what are the acceptable modes of SelectionVector of its child Prel

Specified by:

getSupportedEncodings in interface Prel

getEncoding

public BatchSchema.SelectionVectorMode getEncoding()

Description copied from interface: Prel

A Prel's own SelectionVector mode - i.e whether it generates an SV2, SV4 or None

Specified by:

getEncoding in interface Prel