Uses of Interface
org.apache.drill.exec.planner.physical.Prel

Packages that use Prel

Package	Description
org.apache.drill.exec.planner.physical
org.apache.drill.exec.planner.physical.explain
org.apache.drill.exec.planner.physical.visitor
org.apache.drill.exec.planner.sql.handlers
org.apache.drill.exec.store.enumerable.plan
org.apache.drill.exec.store.jdbc
org.apache.drill.exec.store.phoenix.rules
org.apache.drill.exec.store.plan.rel

Uses of Prel in org.apache.drill.exec.planner.physical

Subinterfaces of Prel in org.apache.drill.exec.planner.physical

Modifier and Type	Interface	Description
interface	DrillScanPrel
interface	LeafPrel	Prel without children.

Classes in org.apache.drill.exec.planner.physical that implement Prel

Modifier and Type	Class	Description
class	AggPrelBase
class	BroadcastExchangePrel
class	ComplexToJsonPrel
class	DirectScanPrel
class	ExchangePrel
class	FilterPrel
class	FlattenPrel
class	HashAggPrel
class	HashJoinPrel
class	HashToMergeExchangePrel
class	HashToRandomExchangePrel
class	JoinPrel	Base class for MergeJoinPrel and HashJoinPrel
class	LateralJoinPrel
class	LimitPrel
class	MergeJoinPrel
class	MetadataControllerPrel
class	MetadataHandlerPrel
class	MetadataHashAggPrel
class	MetadataStreamAggPrel
class	NestedLoopJoinPrel
class	OrderedMuxExchangePrel	OrderedMuxExchangePrel is mux exchange created to multiplex the streams for a MergeReceiver.
class	OrderedPartitionExchangePrel
class	ProducerConsumerPrel
class	ProjectAllowDupPrel
class	ProjectPrel	A physical Prel node for Project operator.
class	RangePartitionExchangePrel	A RangePartitionExchange provides the ability to divide up the rows into separate ranges or 'buckets' based on the values of a set of columns (the range partitioning columns).
class	RowKeyJoinPrel
class	RuntimeFilterPrel
class	ScanPrel
class	ScreenPrel
class	SelectionVectorRemoverPrel
class	SetOpPrel
class	SingleMergeExchangePrel
class	SinglePrel
class	SortPrel
class	StatsAggPrel
class	StatsMergePrel
class	StreamAggPrel
class	TableModifyPrel
class	TopNPrel
class	UnionAllPrel
class	UnionDistinctPrel
class	UnionExchangePrel
class	UnionPrel
class	UnnestPrel
class	UnorderedDeMuxExchangePrel
class	UnorderedMuxExchangePrel
class	UnpivotMapsPrel
class	ValuesPrel	Physical Values implementation in Drill.
class	WindowPrel
class	WriterPrel

Methods in org.apache.drill.exec.planner.physical that return Prel

Modifier and Type	Method	Description
Prel	ExchangePrel.constructMuxPrel(Prel child, OptionManager options)	The derived classes can override this method to create relevant mux exchanges.
Prel	HashToRandomExchangePrel.constructMuxPrel(Prel child, OptionManager options)	This method creates a new UnorderedMux and Demux exchanges if mux operators are enabled.
Prel	SingleMergeExchangePrel.constructMuxPrel(Prel child, OptionManager options)	This method creates a new OrderedMux exchange if mux operators are enabled.
Prel	ValuesPrel.copy(org.apache.calcite.plan.RelTraitSet traitSet, List<org.apache.calcite.rel.RelNode> inputs)
Prel	AggPrelBase.prepareForLateralUnnestPipeline(List<org.apache.calcite.rel.RelNode> children)
Prel	FilterPrel.prepareForLateralUnnestPipeline(List<org.apache.calcite.rel.RelNode> children)
Prel	LimitPrel.prepareForLateralUnnestPipeline(List<org.apache.calcite.rel.RelNode> children)
default 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.
Prel	ProjectPrel.prepareForLateralUnnestPipeline(List<org.apache.calcite.rel.RelNode> children)
Prel	SelectionVectorRemoverPrel.prepareForLateralUnnestPipeline(List<org.apache.calcite.rel.RelNode> children)
Prel	SortPrel.prepareForLateralUnnestPipeline(List<org.apache.calcite.rel.RelNode> children)
Prel	TopNPrel.prepareForLateralUnnestPipeline(List<org.apache.calcite.rel.RelNode> children)
Prel	UnnestPrel.prepareForLateralUnnestPipeline(List<org.apache.calcite.rel.RelNode> children)
static Prel	PrelUtil.removeSvIfRequired(Prel prel, BatchSchema.SelectionVectorMode... allowed)

Methods in org.apache.drill.exec.planner.physical that return types with arguments of type Prel

Modifier and Type	Method	Description
static Iterator<Prel>	PrelUtil.iter(List<org.apache.calcite.rel.RelNode> nodes)
static Iterator<Prel>	PrelUtil.iter(org.apache.calcite.rel.RelNode... nodes)
Iterator<Prel>	AggPrelBase.iterator()
Iterator<Prel>	ComplexToJsonPrel.iterator()
Iterator<Prel>	DirectScanPrel.iterator()
Iterator<Prel>	FilterPrel.iterator()
Iterator<Prel>	FlattenPrel.iterator()
Iterator<Prel>	JoinPrel.iterator()
Iterator<Prel>	LateralJoinPrel.iterator()
default Iterator<Prel>	LeafPrel.iterator()
Iterator<Prel>	LimitPrel.iterator()
Iterator<Prel>	MetadataControllerPrel.iterator()
Iterator<Prel>	MetadataHandlerPrel.iterator()
Iterator<Prel>	MetadataHashAggPrel.iterator()
Iterator<Prel>	MetadataStreamAggPrel.iterator()
Iterator<Prel>	ProducerConsumerPrel.iterator()
Iterator<Prel>	ProjectPrel.iterator()
Iterator<Prel>	RowKeyJoinPrel.iterator()
Iterator<Prel>	ScreenPrel.iterator()
Iterator<Prel>	SetOpPrel.iterator()
Iterator<Prel>	SinglePrel.iterator()
Iterator<Prel>	SortPrel.iterator()
Iterator<Prel>	StatsAggPrel.iterator()
Iterator<Prel>	StatsMergePrel.iterator()
Iterator<Prel>	StreamAggPrel.iterator()
@NotNull Iterator<Prel>	TableModifyPrel.iterator()
Iterator<Prel>	UnionPrel.iterator()
Iterator<Prel>	UnpivotMapsPrel.iterator()
Iterator<Prel>	ValuesPrel.iterator()
Iterator<Prel>	WindowPrel.iterator()
Iterator<Prel>	WriterPrel.iterator()

Methods in org.apache.drill.exec.planner.physical with parameters of type Prel

Modifier and Type	Method	Description
PhysicalOperator	PhysicalPlanCreator.addMetadata(Prel originalPrel, PhysicalOperator op)
PhysicalPlan	PhysicalPlanCreator.build(Prel rootPrel, boolean forceRebuild)
Prel	ExchangePrel.constructMuxPrel(Prel child, OptionManager options)	The derived classes can override this method to create relevant mux exchanges.
Prel	HashToRandomExchangePrel.constructMuxPrel(Prel child, OptionManager options)	This method creates a new UnorderedMux and Demux exchanges if mux operators are enabled.
Prel	SingleMergeExchangePrel.constructMuxPrel(Prel child, OptionManager options)	This method creates a new OrderedMux exchange if mux operators are enabled.
static Prel	PrelUtil.removeSvIfRequired(Prel prel, BatchSchema.SelectionVectorMode... allowed)

Constructors in org.apache.drill.exec.planner.physical with parameters of type Prel

Modifier	Constructor	Description
	ComplexToJsonPrel(Prel phyRelNode)
	RuntimeFilterPrel(Prel child, long identifier)
	SelectionVectorRemoverPrel(Prel child)

Constructor parameters in org.apache.drill.exec.planner.physical with type arguments of type Prel

Modifier	Constructor	Description
	PhysicalPlanCreator(QueryContext context, Map<Prel,PrelSequencer.OpId> opIdMap)

Uses of Prel in org.apache.drill.exec.planner.physical.explain

Methods in org.apache.drill.exec.planner.physical.explain that return types with arguments of type Prel

Modifier and Type	Method	Description
static Map<Prel,PrelSequencer.OpId>	PrelSequencer.getIdMap(Prel rel)
Map<Prel,PrelSequencer.OpId>	PrelSequencer.go(Prel root)

Methods in org.apache.drill.exec.planner.physical.explain with parameters of type Prel

Modifier and Type	Method	Description
static Map<Prel,PrelSequencer.OpId>	PrelSequencer.getIdMap(Prel rel)
Map<Prel,PrelSequencer.OpId>	PrelSequencer.go(Prel root)
static String	PrelSequencer.printWithIds(Prel rel, org.apache.calcite.sql.SqlExplainLevel explainlevel)
Void	PrelSequencer.visitPrel(Prel prel, org.apache.drill.exec.planner.physical.explain.PrelSequencer.Frag value)

Uses of Prel in org.apache.drill.exec.planner.physical.visitor

Methods in org.apache.drill.exec.planner.physical.visitor that return Prel

Modifier and Type	Method	Description
static Prel	ComplexToJsonPrelVisitor.addComplexToJsonPrel(Prel prel)
static Prel	FinalColumnReorderer.addFinalColumnOrdering(Prel prel)
static Prel	ProducerConsumerPrelVisitor.addProducerConsumerToScans(Prel prel, int queueSize)
static Prel	RuntimeFilterVisitor.addRuntimeFilter(Prel prel, QueryContext queryContext)
static Prel	SelectionVectorPrelVisitor.addSelectionRemoversWhereNecessary(Prel prel)
static Prel	AdjustOperatorsSchemaVisitor.adjustSchema(Prel prel)
static Prel	InsertLocalExchangeVisitor.insertLocalExchanges(Prel prel, OptionManager options)
static Prel	StarColumnConverter.insertRenameProject(Prel root)
static Prel	LateralUnnestRowIDVisitor.insertRowID(Prel prel)
static Prel	TopProjectVisitor.insertTopProject(Prel prel, org.apache.calcite.rel.type.RelDataType validatedRowType)	Traverses passed physical relational node and its children and checks if top project should be added under screen or writer to preserve final output fields names.
static Prel	ExcessiveExchangeIdentifier.removeExcessiveExchanges(Prel prel, long targetSliceSize)
static Prel	SwapHashJoinVisitor.swapHashJoin(Prel prel, Double marginFactor)
static Prel	RelUniqifier.uniqifyGraph(Prel p)
Prel	ExcessiveExchangeIdentifier.visitExchange(ExchangePrel prel, org.apache.drill.exec.planner.physical.visitor.ExcessiveExchangeIdentifier.MajorFragmentStat parent)
Prel	InsertLocalExchangeVisitor.visitExchange(ExchangePrel prel, Void value)
Prel	AdjustOperatorsSchemaVisitor.visitJoin(JoinPrel prel, Void value)
Prel	RuntimeFilterVisitor.visitJoin(JoinPrel prel, Void value)
Prel	SwapHashJoinVisitor.visitJoin(JoinPrel prel, Double value)
Prel	AdjustOperatorsSchemaVisitor.visitLateral(LateralJoinPrel prel, Void value)
Prel	ExcessiveExchangeIdentifier.visitLateral(LateralJoinPrel prel, org.apache.drill.exec.planner.physical.visitor.ExcessiveExchangeIdentifier.MajorFragmentStat s)
Prel	LateralUnnestRowIDVisitor.visitLateral(LateralJoinPrel prel, Boolean isRightOfLateral)
Prel	StarColumnConverter.visitLeaf(LeafPrel prel, Void value)
Prel	AdjustOperatorsSchemaVisitor.visitPrel(Prel prel, Void value)
Prel	ExcessiveExchangeIdentifier.visitPrel(Prel prel, org.apache.drill.exec.planner.physical.visitor.ExcessiveExchangeIdentifier.MajorFragmentStat s)
Prel	FinalColumnReorderer.visitPrel(Prel prel, Void value)
Prel	InsertLocalExchangeVisitor.visitPrel(Prel prel, Void value)
Prel	LateralUnnestRowIDVisitor.visitPrel(Prel prel, Boolean isRightOfLateral)
Prel	ProducerConsumerPrelVisitor.visitPrel(Prel prel, Void value)
Prel	RelUniqifier.visitPrel(Prel prel, Set<Prel> data)
Prel	RewriteProjectToFlatten.visitPrel(Prel prel, Object value)
Prel	RuntimeFilterVisitor.visitPrel(Prel prel, Void value)
Prel	SelectionVectorPrelVisitor.visitPrel(Prel prel, Void value)
Prel	SplitUpComplexExpressions.visitPrel(Prel prel, Object unused)
Prel	StarColumnConverter.visitPrel(Prel prel, Void value)
Prel	SwapHashJoinVisitor.visitPrel(Prel prel, Double value)
Prel	TopProjectVisitor.visitPrel(Prel prel, Void value)
Prel	RewriteProjectToFlatten.visitProject(ProjectPrel project, Object unused)
Prel	SplitUpComplexExpressions.visitProject(ProjectPrel project, Object unused)
Prel	StarColumnConverter.visitProject(ProjectPrel prel, Void value)
Prel	ExcessiveExchangeIdentifier.visitScan(ScanPrel prel, org.apache.drill.exec.planner.physical.visitor.ExcessiveExchangeIdentifier.MajorFragmentStat s)
Prel	ProducerConsumerPrelVisitor.visitScan(ScanPrel scanPrel, Void value)
Prel	RuntimeFilterVisitor.visitScan(ScanPrel prel, Void value)
Prel	StarColumnConverter.visitScan(ScanPrel scanPrel, Void value)
Prel	ComplexToJsonPrelVisitor.visitScreen(ScreenPrel prel, Void value)
Prel	ExcessiveExchangeIdentifier.visitScreen(ScreenPrel prel, org.apache.drill.exec.planner.physical.visitor.ExcessiveExchangeIdentifier.MajorFragmentStat s)
Prel	FinalColumnReorderer.visitScreen(ScreenPrel prel, Void value)
Prel	StarColumnConverter.visitScreen(ScreenPrel prel, Void value)
Prel	TopProjectVisitor.visitScreen(ScreenPrel prel, Void value)
Prel	AdjustOperatorsSchemaVisitor.visitUnnest(UnnestPrel prel, Void value)
Prel	ExcessiveExchangeIdentifier.visitUnnest(UnnestPrel prel, org.apache.drill.exec.planner.physical.visitor.ExcessiveExchangeIdentifier.MajorFragmentStat s)
Prel	LateralUnnestRowIDVisitor.visitUnnest(UnnestPrel prel, Boolean isRightOfLateral)
Prel	StarColumnConverter.visitUnnest(UnnestPrel unnestPrel, Void value)
Prel	FinalColumnReorderer.visitWriter(WriterPrel prel, Void value)
Prel	StarColumnConverter.visitWriter(WriterPrel prel, Void value)
Prel	TopProjectVisitor.visitWriter(WriterPrel prel, Void value)

Methods in org.apache.drill.exec.planner.physical.visitor with parameters of type Prel

Modifier and Type	Method	Description
static Prel	ComplexToJsonPrelVisitor.addComplexToJsonPrel(Prel prel)
static Prel	FinalColumnReorderer.addFinalColumnOrdering(Prel prel)
static Prel	ProducerConsumerPrelVisitor.addProducerConsumerToScans(Prel prel, int queueSize)
static Prel	RuntimeFilterVisitor.addRuntimeFilter(Prel prel, QueryContext queryContext)
static Prel	SelectionVectorPrelVisitor.addSelectionRemoversWhereNecessary(Prel prel)
static Prel	AdjustOperatorsSchemaVisitor.adjustSchema(Prel prel)
static boolean	MemoryEstimationVisitor.enoughMemory(Prel prel, OptionManager options, int numDrillbits)
static Double	MemoryEstimationVisitor.estimateMemory(Prel prel)
static Prel	InsertLocalExchangeVisitor.insertLocalExchanges(Prel prel, OptionManager options)
static Prel	StarColumnConverter.insertRenameProject(Prel root)
static Prel	LateralUnnestRowIDVisitor.insertRowID(Prel prel)
static Prel	TopProjectVisitor.insertTopProject(Prel prel, org.apache.calcite.rel.type.RelDataType validatedRowType)	Traverses passed physical relational node and its children and checks if top project should be added under screen or writer to preserve final output fields names.
static void	PrelVisualizerVisitor.print(String label, Prel prel)
static Prel	ExcessiveExchangeIdentifier.removeExcessiveExchanges(Prel prel, long targetSliceSize)
void	PrelVisualizerVisitor.VisualizationState.startNode(Prel prel)
static Prel	SwapHashJoinVisitor.swapHashJoin(Prel prel, Double marginFactor)
static Prel	RelUniqifier.uniqifyGraph(Prel p)
Prel	AdjustOperatorsSchemaVisitor.visitPrel(Prel prel, Void value)
RETURN	BasePrelVisitor.visitPrel(Prel prel, EXTRA value)
Prel	ExcessiveExchangeIdentifier.visitPrel(Prel prel, org.apache.drill.exec.planner.physical.visitor.ExcessiveExchangeIdentifier.MajorFragmentStat s)
Prel	FinalColumnReorderer.visitPrel(Prel prel, Void value)
Prel	InsertLocalExchangeVisitor.visitPrel(Prel prel, Void value)
Prel	LateralUnnestRowIDVisitor.visitPrel(Prel prel, Boolean isRightOfLateral)
Double	MemoryEstimationVisitor.visitPrel(Prel prel, Void value)
RETURN	PrelVisitor.visitPrel(Prel prel, EXTRA value)
Void	PrelVisualizerVisitor.visitPrel(Prel prel, PrelVisualizerVisitor.VisualizationState value)
Prel	ProducerConsumerPrelVisitor.visitPrel(Prel prel, Void value)
Prel	RelUniqifier.visitPrel(Prel prel, Set<Prel> data)
Prel	RewriteProjectToFlatten.visitPrel(Prel prel, Object value)
Prel	RuntimeFilterVisitor.visitPrel(Prel prel, Void value)
Prel	SelectionVectorPrelVisitor.visitPrel(Prel prel, Void value)
Prel	SplitUpComplexExpressions.visitPrel(Prel prel, Object unused)
Prel	StarColumnConverter.visitPrel(Prel prel, Void value)
Prel	SwapHashJoinVisitor.visitPrel(Prel prel, Double value)
Prel	TopProjectVisitor.visitPrel(Prel prel, Void value)
static String	PrelVisualizerVisitor.visualize(Prel prel)

Method parameters in org.apache.drill.exec.planner.physical.visitor with type arguments of type Prel

Modifier and Type	Method	Description
Prel	RelUniqifier.visitPrel(Prel prel, Set<Prel> data)

Uses of Prel in org.apache.drill.exec.planner.sql.handlers

Methods in org.apache.drill.exec.planner.sql.handlers that return Prel

Modifier and Type	Method	Description
protected Prel	DefaultSqlHandler.convertToPrel(org.apache.calcite.rel.RelNode drel, org.apache.calcite.rel.type.RelDataType validatedRowType)	Applies physical rules and certain transformations to convert drill relational node into physical one.
Prel	PrelFinalizable.finalizeRel()

Methods in org.apache.drill.exec.planner.sql.handlers with parameters of type Prel

Modifier and Type	Method	Description
protected PhysicalOperator	DefaultSqlHandler.convertToPop(Prel prel)
protected void	DefaultSqlHandler.logAndSetTextPlan(String description, Prel prel, org.slf4j.Logger logger)
static void	ExplainHandler.printPlan(Prel node, QueryContext context)

Uses of Prel in org.apache.drill.exec.store.enumerable.plan

Classes in org.apache.drill.exec.store.enumerable.plan that implement Prel

Modifier and Type	Class	Description
class	EnumerableIntermediatePrel
class	EnumerablePrel	LeafPrel implementation that generates java code that may be executed to obtain results for the provided plan part.

Methods in org.apache.drill.exec.store.enumerable.plan that return Prel

Modifier and Type	Method	Description
Prel	EnumerableIntermediatePrel.finalizeRel()

Uses of Prel in org.apache.drill.exec.store.jdbc

Classes in org.apache.drill.exec.store.jdbc that implement Prel

Modifier and Type	Class	Description
class	JdbcIntermediatePrel	Prel used to represent a JDBC Conversion within an expression tree.
class	JdbcPrel	Represents a JDBC Plan once the children nodes have been rewritten into SQL.

Methods in org.apache.drill.exec.store.jdbc that return Prel

Modifier and Type	Method	Description
Prel	JdbcIntermediatePrel.finalizeRel()

Methods in org.apache.drill.exec.store.jdbc that return types with arguments of type Prel

Modifier and Type	Method	Description
Iterator<Prel>	JdbcPrel.iterator()

Uses of Prel in org.apache.drill.exec.store.phoenix.rules

Classes in org.apache.drill.exec.store.phoenix.rules that implement Prel

Modifier and Type	Class	Description
class	PhoenixIntermediatePrel
class	PhoenixPrel

Methods in org.apache.drill.exec.store.phoenix.rules that return Prel

Modifier and Type	Method	Description
Prel	PhoenixIntermediatePrel.finalizeRel()

Methods in org.apache.drill.exec.store.phoenix.rules that return types with arguments of type Prel

Modifier and Type	Method	Description
Iterator<Prel>	PhoenixPrel.iterator()

Uses of Prel in org.apache.drill.exec.store.plan.rel

Classes in org.apache.drill.exec.store.plan.rel that implement Prel

Modifier and Type	Class	Description
class	PluginIntermediatePrel	Prel used to represent a Plugin Conversion within an expression tree.
class	PluginPrel	Represents a plugin-specific plan once children nodes have been pushed down into group scan.

Methods in org.apache.drill.exec.store.plan.rel that return Prel

Modifier and Type	Method	Description
Prel	PluginIntermediatePrel.finalizeRel()