org.apache.drill.exec.planner.physical

Interface Prel

All Superinterfaces:

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

All Known Subinterfaces:

DrillScanPrel, LeafPrel

All Known Implementing Classes:

AggPrelBase, BroadcastExchangePrel, ComplexToJsonPrel, DirectScanPrel, EnumerableIntermediatePrel, EnumerablePrel, ExchangePrel, FilterPrel, FlattenPrel, HashAggPrel, HashJoinPrel, HashToMergeExchangePrel, HashToRandomExchangePrel, JdbcIntermediatePrel, JdbcPrel, JoinPrel, LateralJoinPrel, LimitPrel, MergeJoinPrel, MetadataControllerPrel, MetadataHandlerPrel, MetadataHashAggPrel, MetadataStreamAggPrel, NestedLoopJoinPrel, OrderedMuxExchangePrel, OrderedPartitionExchangePrel, PhoenixIntermediatePrel, PhoenixPrel, PluginIntermediatePrel, PluginPrel, ProducerConsumerPrel, ProjectAllowDupPrel, ProjectPrel, RangePartitionExchangePrel, RowKeyJoinPrel, RuntimeFilterPrel, ScanPrel, ScreenPrel, SelectionVectorRemoverPrel, SingleMergeExchangePrel, SinglePrel, SortPrel, StatsAggPrel, StatsMergePrel, StreamAggPrel, TopNPrel, UnionAllPrel, UnionDistinctPrel, UnionExchangePrel, UnionPrel, UnnestPrel, UnorderedDeMuxExchangePrel, UnorderedMuxExchangePrel, UnpivotMapsPrel, ValuesPrel, WindowPrel, WriterPrel

public interface Prel
extends DrillRelNode, Iterable<Prel>

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
static org.apache.calcite.plan.Convention	DRILL_PHYSICAL

Method Summary

Modifier and Type	Method and Description
<T,X,E extends Throwable> T	accept(PrelVisitor<T,X,E> logicalVisitor, X value)
BatchSchema.SelectionVectorMode	getEncoding() A Prel's own SelectionVector mode - i.e whether it generates an SV2, SV4 or None
PhysicalOperator	getPhysicalOperator(PhysicalPlanCreator creator)
BatchSchema.SelectionVectorMode[]	getSupportedEncodings() Supported 'encodings' of a Prel indicates what are the acceptable modes of SelectionVector of its child Prel
boolean	needsFinalColumnReordering()
default 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 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, iterator, spliterator

Field Detail

DRILL_PHYSICAL

static final org.apache.calcite.plan.Convention DRILL_PHYSICAL

Method Detail

getPhysicalOperator

PhysicalOperator getPhysicalOperator(PhysicalPlanCreator creator)
                              throws IOException

Throws:

IOException

accept

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

Throws:

E extends Throwable

getSupportedEncodings

BatchSchema.SelectionVectorMode[] getSupportedEncodings()

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

getEncoding

BatchSchema.SelectionVectorMode getEncoding()

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

needsFinalColumnReordering

boolean needsFinalColumnReordering()

prepareForLateralUnnestPipeline

default 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. eg: TopNPrel -> SortPrel and LimitPrel Other operators like FilterPrel, ProjectPrel etc will add an implicit row id to the output.