org.apache.drill.exec.planner.physical

Class UnnestPrel

java.lang.Object

org.apache.calcite.rel.AbstractRelNode

org.apache.drill.exec.planner.common.DrillUnnestRelBase

org.apache.drill.exec.planner.physical.UnnestPrel

All Implemented Interfaces:

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

public class UnnestPrel
extends DrillUnnestRelBase
implements LeafPrel

Nested Class Summary

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

org.apache.calcite.rel.RelNode.Context

Field Summary

Fields

Modifier and Type	Field and Description
protected UnnestPOP	unnestPOP

Fields inherited from class org.apache.drill.exec.planner.common.DrillUnnestRelBase

IMPLICIT_COLUMN, ref

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

Constructor and Description
UnnestPrel(org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.plan.RelTraitSet traits, org.apache.calcite.rel.type.RelDataType rowType, org.apache.calcite.rex.RexNode ref)

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.RelNode	accept(org.apache.calcite.rex.RexShuttle shuttle)
BatchSchema.SelectionVectorMode	getEncoding() A Prel's own SelectionVector mode - i.e whether it generates an SV2, SV4 or None
Class<?>	getParentClass()
PhysicalOperator	getPhysicalOperator(PhysicalPlanCreator creator)
BatchSchema.SelectionVectorMode[]	getSupportedEncodings() Supported 'encodings' of a Prel indicates what are the acceptable modes of SelectionVector of its child Prel
Prel	prepareForLateralUnnestPipeline(List<org.apache.calcite.rel.RelNode> children) If the operator is in Lateral/Unnest pipeline, then it generates a new operator which knows how to process the rows accordingly during execution.

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

computeSelfCost, getRef

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

accept, childrenAccept, collectVariablesSet, collectVariablesUsed, computeDigest, computeSelfCost, copy, deriveRowType, equals, estimateRowCount, explain, explainTerms, getChildExps, getCluster, getCollationList, getConvention, getCorrelVariable, getDescription, getDigest, getExpectedInputRowType, getId, getInput, getInputs, getQuery, getRelTypeName, getRows, getRowType, getTable, getTraitSet, getVariablesSet, getVariablesStopped, hashCode, isDistinct, isKey, isValid, isValid, metadata, onRegister, recomputeDigest, register, replaceInput, 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.LeafPrel

iterator, needsFinalColumnReordering

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

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

Field Detail

unnestPOP

protected final UnnestPOP unnestPOP

Constructor Detail

UnnestPrel

public UnnestPrel(org.apache.calcite.plan.RelOptCluster cluster,
                  org.apache.calcite.plan.RelTraitSet traits,
                  org.apache.calcite.rel.type.RelDataType rowType,
                  org.apache.calcite.rex.RexNode ref)

Method Detail

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

getPhysicalOperator

public PhysicalOperator getPhysicalOperator(PhysicalPlanCreator creator)
                                     throws IOException

Specified by:

getPhysicalOperator in interface Prel

Throws:

IOException

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

getParentClass

public Class<?> getParentClass()

accept

public org.apache.calcite.rel.RelNode accept(org.apache.calcite.rex.RexShuttle shuttle)

Specified by:

accept in interface org.apache.calcite.rel.RelNode

Overrides:

accept in class org.apache.calcite.rel.AbstractRelNode

prepareForLateralUnnestPipeline

public Prel prepareForLateralUnnestPipeline(List<org.apache.calcite.rel.RelNode> children)

Description copied from interface: Prel

If the operator is in Lateral/Unnest pipeline, then it generates a new operator which knows how to process the rows accordingly during execution. eg: TopNPrel -> SortPrel and LimitPrel Other operators like FilterPrel, ProjectPrel etc will add an implicit row id to the output.

Specified by:

prepareForLateralUnnestPipeline in interface Prel