Uses of Interface
org.apache.drill.exec.physical.base.PhysicalOperator

Packages that use PhysicalOperator

Package	Description
org.apache.drill.exec.ops
org.apache.drill.exec.physical
org.apache.drill.exec.physical.base
org.apache.drill.exec.physical.config
org.apache.drill.exec.physical.impl
org.apache.drill.exec.physical.impl.protocol	Defines a revised implementation of the Drill RecordBatch protocol.
org.apache.drill.exec.physical.impl.scan.project	Provides run-time semantic analysis of the projection list for the scan operator.
org.apache.drill.exec.physical.impl.scan.v3	Provides the "version 3" scan framework (which can also be thought of as EVF version 2).
org.apache.drill.exec.physical.impl.spill	Collection of classes shared by operators that implement spill-to-disk.
org.apache.drill.exec.physical.impl.validate
org.apache.drill.exec.planner
org.apache.drill.exec.planner.fragment
org.apache.drill.exec.planner.fragment.contrib
org.apache.drill.exec.planner.logical
org.apache.drill.exec.planner.physical
org.apache.drill.exec.planner.sql.handlers
org.apache.drill.exec.record
org.apache.drill.exec.store.dfs
org.apache.drill.exec.store.dfs.easy
org.apache.drill.exec.store.direct
org.apache.drill.exec.store.druid
org.apache.drill.exec.store.enumerable
org.apache.drill.exec.store.enumerable.plan
org.apache.drill.exec.store.hbase
org.apache.drill.exec.store.hive
org.apache.drill.exec.store.http
org.apache.drill.exec.store.iceberg
org.apache.drill.exec.store.iceberg.format
org.apache.drill.exec.store.ischema
org.apache.drill.exec.store.jdbc
org.apache.drill.exec.store.kafka	Kafka storage plugin.
org.apache.drill.exec.store.kudu
org.apache.drill.exec.store.mapr
org.apache.drill.exec.store.mapr.db
org.apache.drill.exec.store.mapr.db.binary
org.apache.drill.exec.store.mapr.db.json
org.apache.drill.exec.store.mapr.streams
org.apache.drill.exec.store.mock	Defines a mock data source which generates dummy test data for use in testing.
org.apache.drill.exec.store.mongo	MongoDB storage plugin.
org.apache.drill.exec.store.openTSDB
org.apache.drill.exec.store.parquet
org.apache.drill.exec.store.phoenix
org.apache.drill.exec.store.phoenix.rules
org.apache.drill.exec.store.plan.rel
org.apache.drill.exec.store.splunk
org.apache.drill.exec.store.sys
org.apache.drill.exec.util
org.apache.drill.exec.work.filter
org.apache.drill.exec.work.foreman.rm	Provides resource management and queuing support for the Drill foreman.

Uses of PhysicalOperator in org.apache.drill.exec.ops

Fields in org.apache.drill.exec.ops declared as PhysicalOperator

Modifier and Type	Field and Description
protected PhysicalOperator	BaseOperatorContext.popConfig

Methods in org.apache.drill.exec.ops with type parameters of type PhysicalOperator

Modifier and Type	Method and Description
<T extends PhysicalOperator> T	BaseOperatorContext.getOperatorDefn()
<T extends PhysicalOperator> T	OperatorContext.getOperatorDefn() Return the physical operator definition created by the planner and passed into the Drillbit executing the query.

Methods in org.apache.drill.exec.ops with parameters of type PhysicalOperator

Modifier and Type	Method and Description
static int	OperatorUtilities.getChildCount(PhysicalOperator popConfig)
OperatorContext	FragmentContextInterface.newOperatorContext(PhysicalOperator popConfig)
OperatorContext	FragmentContext.newOperatorContext(PhysicalOperator popConfig)
OperatorContext	FragmentContextImpl.newOperatorContext(PhysicalOperator popConfig)
OperatorContext	FragmentContextInterface.newOperatorContext(PhysicalOperator popConfig, OperatorStats stats)
OperatorContext	FragmentContext.newOperatorContext(PhysicalOperator popConfig, OperatorStats stats)
OperatorContext	FragmentContextImpl.newOperatorContext(PhysicalOperator popConfig, OperatorStats stats)

Constructors in org.apache.drill.exec.ops with parameters of type PhysicalOperator

Constructor and Description
BaseOperatorContext(FragmentContext context, BufferAllocator allocator, PhysicalOperator popConfig)

Uses of PhysicalOperator in org.apache.drill.exec.physical

Fields in org.apache.drill.exec.physical with type parameters of type PhysicalOperator

Modifier and Type	Field and Description
protected Graph<PhysicalOperator,Root,Leaf>	PhysicalPlan.graph

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

Modifier and Type	Method and Description
List<PhysicalOperator>	PhysicalPlan.getSortedOperators()
List<PhysicalOperator>	PhysicalPlan.getSortedOperators(boolean reverse)
Graph<PhysicalOperator,Root,Leaf>	PhysicalPlan.graph()

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

Constructor and Description
PhysicalPlan(PlanProperties properties, List<PhysicalOperator> operators)

Uses of PhysicalOperator in org.apache.drill.exec.physical.base

Subinterfaces of PhysicalOperator in org.apache.drill.exec.physical.base

Modifier and Type	Interface and Description
interface	DbGroupScan A DbGroupScan operator represents the scan associated with a database.
interface	DbSubScan
interface	Exchange
interface	FileGroupScan FileGroupScan operator represents all data which will be scanned from FileSystem by a given physical plan.
interface	FragmentLeaf A Physical Operator that can be the leaf node of one particular execution fragment.
interface	FragmentRoot Describes the root operation within a particular Fragment.
interface	GroupScan A GroupScan operator represents all data which will be scanned by a given physical plan.
interface	HasAffinity Describes a physical operator that has affinity to particular nodes.
interface	IndexGroupScan An IndexGroupScan operator represents the scan associated with an Index.
interface	Leaf Operator which specifically is a lowest level leaf node of a query plan across all possible fragments.
interface	Receiver A receiver is one half of an exchange operator.
interface	Root Marker interface describe the root of a query plan.
interface	Scan
interface	Sender A sender is one half of an exchange node operations.
interface	Store An interface which supports storing a record stream.
interface	SubScan A SubScan operator represents the data scanned by a particular major/minor fragment.
interface	Writer Writer physical operator

Classes in org.apache.drill.exec.physical.base that implement PhysicalOperator

Modifier and Type	Class and Description
class	AbstractBase
class	AbstractDbGroupScan
class	AbstractDbSubScan
class	AbstractExchange
class	AbstractFileGroupScan
class	AbstractGroupScan
class	AbstractGroupScanWithMetadata<P extends TableMetadataProvider> Represents table group scan with metadata usage.
class	AbstractJoinPop
class	AbstractMultiple Describes an operator that expects more than one children operators as its input.
class	AbstractReceiver
class	AbstractSender
class	AbstractSingle Describes an operator that expects a single child operator as its input.
class	AbstractStore
class	AbstractSubScan
class	AbstractWriter
class	SchemalessScan The type of scan operator, which allows to scan schemaless tables (DynamicDrillTable with null selection)

Fields in org.apache.drill.exec.physical.base declared as PhysicalOperator

Modifier and Type	Field and Description
protected PhysicalOperator	AbstractSingle.child
protected PhysicalOperator	AbstractJoinPop.left
protected PhysicalOperator	AbstractJoinPop.right

Fields in org.apache.drill.exec.physical.base with type parameters of type PhysicalOperator

Modifier and Type	Field and Description
protected List<PhysicalOperator>	AbstractMultiple.children

Methods in org.apache.drill.exec.physical.base that return PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	AbstractSingle.getChild()
PhysicalOperator	Exchange.getChild() Return the feeding child of this operator node.
PhysicalOperator	Store.getChild() Get the child of this store operator as this will be needed for parallelization materialization purposes.
PhysicalOperator	AbstractJoinPop.getLeft()
protected abstract PhysicalOperator	AbstractSingle.getNewWithChild(PhysicalOperator child)
PhysicalOperator	AbstractReceiver.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	AbstractSingle.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	AbstractSubScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	SchemalessScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	PhysicalOperator.getNewWithChildren(List<PhysicalOperator> children) Regenerate with this node with a new set of children.
PhysicalOperator	AbstractJoinPop.getRight()

Methods in org.apache.drill.exec.physical.base that return types with arguments of type PhysicalOperator

Modifier and Type	Method and Description
List<PhysicalOperator>	AbstractMultiple.getChildren()
static Set<Class<? extends PhysicalOperator>>	PhysicalOperatorUtil.getSubTypes(ScanResult classpathScan)
Iterator<PhysicalOperator>	AbstractJoinPop.iterator()
Iterator<PhysicalOperator>	AbstractMultiple.iterator()
Iterator<PhysicalOperator>	AbstractReceiver.iterator()
Iterator<PhysicalOperator>	AbstractSingle.iterator()
Iterator<PhysicalOperator>	AbstractSubScan.iterator()
Iterator<PhysicalOperator>	AbstractGroupScan.iterator()

Methods in org.apache.drill.exec.physical.base with parameters of type PhysicalOperator

Modifier and Type	Method and Description
protected abstract PhysicalOperator	AbstractSingle.getNewWithChild(PhysicalOperator child)
Sender	Exchange.getSender(int minorFragmentId, PhysicalOperator child) Get the Sender associated with the given minorFragmentId.
Store	Store.getSpecificStore(PhysicalOperator child, int minorFragmentId) Provides full materialized Store operators for execution purposes.
T	AbstractPhysicalVisitor.visitChildren(PhysicalOperator op, X value)
RETURN	PhysicalVisitor.visitOp(PhysicalOperator op, EXTRA value)
T	AbstractPhysicalVisitor.visitOp(PhysicalOperator op, X value)

Method parameters in org.apache.drill.exec.physical.base with type arguments of type PhysicalOperator

Modifier and Type	Method and Description
void	AbstractSubScan.accept(GraphVisitor<PhysicalOperator> visitor)
void	AbstractBase.accept(GraphVisitor<PhysicalOperator> visitor)
PhysicalOperator	AbstractReceiver.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	AbstractSingle.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	AbstractSubScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	SchemalessScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	PhysicalOperator.getNewWithChildren(List<PhysicalOperator> children) Regenerate with this node with a new set of children.

Constructors in org.apache.drill.exec.physical.base with parameters of type PhysicalOperator

Constructor and Description
AbstractExchange(PhysicalOperator child)
AbstractJoinPop(PhysicalOperator leftOp, PhysicalOperator rightOp, org.apache.calcite.rel.core.JoinRelType joinType, boolean semiJoin, LogicalExpression joinCondition, List<JoinCondition> joinConditions)
AbstractSender(int oppositeMajorFragmentId, PhysicalOperator child, List<MinorFragmentEndpoint> destinations)
AbstractSingle(PhysicalOperator child)
AbstractStore(PhysicalOperator child)
AbstractWriter(PhysicalOperator child)

Constructor parameters in org.apache.drill.exec.physical.base with type arguments of type PhysicalOperator

Constructor and Description
AbstractMultiple(List<PhysicalOperator> children)

Uses of PhysicalOperator in org.apache.drill.exec.physical.config

Classes in org.apache.drill.exec.physical.config that implement PhysicalOperator

Modifier and Type	Class and Description
class	AbstractDeMuxExchange DeMuxExchange is opposite of MuxExchange.
class	AbstractMuxExchange Multiplexing Exchange (MuxExchange) is used when results from multiple minor fragments belonging to the same major fragment running on a node need to be collected at one fragment on the same node before distributing the results further.
class	BroadcastExchange
class	BroadcastSender
class	ComplexToJson
class	ExternalSort
class	Filter
class	FlattenPOP
class	HashAggregate
class	HashJoinPOP
class	HashPartitionSender
class	HashToMergeExchange
class	HashToRandomExchange
class	IteratorValidator
class	LateralJoinPOP
class	Limit
class	MergeJoinPOP
class	MergingReceiverPOP
class	MetadataControllerPOP
class	MetadataHandlerPOP
class	MetadataHashAggPOP
class	MetadataStreamAggPOP
class	NestedLoopJoinPOP
class	OrderedMuxExchange OrderedMuxExchange is a version of MuxExchange where the incoming batches are sorted merge operation is performed to produced a sorted stream as output.
class	OrderedPartitionExchange
class	OrderedPartitionSender
class	PartitionLimit
class	ProducerConsumer
class	Project
class	RangePartitionExchange
class	RangePartitionSender
class	RowKeyJoinPOP
class	RuntimeFilterPOP
class	Screen
class	SelectionVectorRemover
class	SingleMergeExchange
class	SingleSender Sender that pushes all data to a single destination node.
class	Sort
class	StatisticsAggregate
class	StatisticsMerge
class	StreamingAggregate
class	TopN
class	Trace
class	UnionAll
class	UnionExchange
class	UnnestPOP
class	UnorderedDeMuxExchange UnorderedDeMuxExchange is a version of DeMuxExchange where the incoming batches are not sorted.
class	UnorderedMuxExchange UnorderedMuxExchange is a version of MuxExchange where the incoming batches are not sorted.
class	UnorderedReceiver
class	UnpivotMaps
class	Values
class	WindowPOP

Methods in org.apache.drill.exec.physical.config that return PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	MetadataControllerPOP.getLeft()
PhysicalOperator	RowKeyJoinPOP.getLeft()
protected PhysicalOperator	BroadcastExchange.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	BroadcastSender.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	ComplexToJson.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	Filter.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	FlattenPOP.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	HashPartitionSender.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	HashToMergeExchange.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	HashToRandomExchange.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	IteratorValidator.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	Limit.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	MetadataHandlerPOP.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	MetadataHashAggPOP.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	MetadataStreamAggPOP.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	OrderedMuxExchange.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	OrderedPartitionExchange.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	OrderedPartitionSender.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	PartitionLimit.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	ProducerConsumer.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	Project.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	RangePartitionExchange.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	RangePartitionSender.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	RuntimeFilterPOP.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	Screen.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	SelectionVectorRemover.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	SingleMergeExchange.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	SingleSender.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	Sort.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	StatisticsAggregate.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	StatisticsMerge.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	StreamingAggregate.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	TopN.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	Trace.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	UnionExchange.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	UnorderedDeMuxExchange.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	UnorderedMuxExchange.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	UnpivotMaps.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	WindowPOP.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	ExternalSort.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	HashAggregate.getNewWithChild(PhysicalOperator child)
PhysicalOperator	LateralJoinPOP.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	MergeJoinPOP.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	MetadataControllerPOP.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	NestedLoopJoinPOP.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	RowKeyJoinPOP.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	UnionAll.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	UnnestPOP.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	HashJoinPOP.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	Values.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	MetadataControllerPOP.getRight()
PhysicalOperator	RowKeyJoinPOP.getRight()

Methods in org.apache.drill.exec.physical.config that return types with arguments of type PhysicalOperator

Modifier and Type	Method and Description
Iterator<PhysicalOperator>	FlattenPOP.iterator()
Iterator<PhysicalOperator>	MetadataControllerPOP.iterator()
Iterator<PhysicalOperator>	RowKeyJoinPOP.iterator()
Iterator<PhysicalOperator>	UnnestPOP.iterator()
Iterator<PhysicalOperator>	Values.iterator()

Methods in org.apache.drill.exec.physical.config with parameters of type PhysicalOperator

Modifier and Type	Method and Description
protected PhysicalOperator	BroadcastExchange.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	BroadcastSender.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	ComplexToJson.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	Filter.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	FlattenPOP.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	HashPartitionSender.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	HashToMergeExchange.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	HashToRandomExchange.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	IteratorValidator.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	Limit.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	MetadataHandlerPOP.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	MetadataHashAggPOP.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	MetadataStreamAggPOP.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	OrderedMuxExchange.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	OrderedPartitionExchange.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	OrderedPartitionSender.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	PartitionLimit.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	ProducerConsumer.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	Project.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	RangePartitionExchange.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	RangePartitionSender.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	RuntimeFilterPOP.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	Screen.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	SelectionVectorRemover.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	SingleMergeExchange.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	SingleSender.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	Sort.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	StatisticsAggregate.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	StatisticsMerge.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	StreamingAggregate.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	TopN.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	Trace.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	UnionExchange.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	UnorderedDeMuxExchange.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	UnorderedMuxExchange.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	UnpivotMaps.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	WindowPOP.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	ExternalSort.getNewWithChild(PhysicalOperator child)
protected PhysicalOperator	HashAggregate.getNewWithChild(PhysicalOperator child)
Sender	AbstractDeMuxExchange.getSender(int minorFragmentId, PhysicalOperator child)
Sender	AbstractMuxExchange.getSender(int minorFragmentId, PhysicalOperator child)
Sender	BroadcastExchange.getSender(int minorFragmentId, PhysicalOperator child)
Sender	HashToMergeExchange.getSender(int minorFragmentId, PhysicalOperator child)
Sender	HashToRandomExchange.getSender(int minorFragmentId, PhysicalOperator child)
Sender	OrderedPartitionExchange.getSender(int minorFragmentId, PhysicalOperator child)
Sender	RangePartitionExchange.getSender(int minorFragmentId, PhysicalOperator child)
Sender	SingleMergeExchange.getSender(int minorFragmentId, PhysicalOperator child)
Sender	UnionExchange.getSender(int minorFragmentId, PhysicalOperator child)
Store	Screen.getSpecificStore(PhysicalOperator child, int minorFragmentId)

Method parameters in org.apache.drill.exec.physical.config with type arguments of type PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	LateralJoinPOP.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	MergeJoinPOP.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	MetadataControllerPOP.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	NestedLoopJoinPOP.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	RowKeyJoinPOP.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	UnionAll.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	UnnestPOP.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	HashJoinPOP.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	Values.getNewWithChildren(List<PhysicalOperator> children)

Constructors in org.apache.drill.exec.physical.config with parameters of type PhysicalOperator

Constructor and Description
AbstractDeMuxExchange(PhysicalOperator child, LogicalExpression expr)
AbstractMuxExchange(PhysicalOperator child)
BroadcastExchange(PhysicalOperator child)
BroadcastSender(int oppositeMajorFragmentId, PhysicalOperator child, List<MinorFragmentEndpoint> destinations)
ComplexToJson(PhysicalOperator child)
ExternalSort(PhysicalOperator child, List<Order.Ordering> orderings, boolean reverse)
Filter(PhysicalOperator child, LogicalExpression expr, float selectivity)
FlattenPOP(PhysicalOperator child, SchemaPath column)
HashAggregate(PhysicalOperator child, AggPrelBase.OperatorPhase aggPhase, List<NamedExpression> groupByExprs, List<NamedExpression> aggrExprs, float cardinality)
HashJoinPOP(PhysicalOperator left, PhysicalOperator right, List<JoinCondition> conditions, org.apache.calcite.rel.core.JoinRelType joinType)
HashJoinPOP(PhysicalOperator left, PhysicalOperator right, List<JoinCondition> conditions, org.apache.calcite.rel.core.JoinRelType joinType, boolean semiJoin, RuntimeFilterDef runtimeFilterDef, boolean isRowKeyJoin, int joinControl)
HashJoinPOP(PhysicalOperator left, PhysicalOperator right, List<JoinCondition> conditions, org.apache.calcite.rel.core.JoinRelType joinType, RuntimeFilterDef runtimeFilterDef)
HashJoinPOP(PhysicalOperator left, PhysicalOperator right, List<JoinCondition> conditions, org.apache.calcite.rel.core.JoinRelType joinType, RuntimeFilterDef runtimeFilterDef, boolean isRowKeyJoin, int joinControl)
HashPartitionSender(int oppositeMajorFragmentId, PhysicalOperator child, LogicalExpression expr, List<MinorFragmentEndpoint> endpoints)
HashPartitionSender(int oppositeMajorFragmentId, PhysicalOperator child, LogicalExpression expr, List<MinorFragmentEndpoint> endpoints, int outgoingBatchSize)
HashToMergeExchange(PhysicalOperator child, LogicalExpression expr, List<Order.Ordering> orderExprs)
HashToRandomExchange(PhysicalOperator child, LogicalExpression expr)
IteratorValidator(PhysicalOperator child)
IteratorValidator(PhysicalOperator child, boolean repeatable)
LateralJoinPOP(PhysicalOperator left, PhysicalOperator right, org.apache.calcite.rel.core.JoinRelType joinType, String implicitRIDColumn, List<SchemaPath> excludedColumns)
Limit(PhysicalOperator child, Integer first, Integer last)
MergeJoinPOP(PhysicalOperator left, PhysicalOperator right, List<JoinCondition> conditions, org.apache.calcite.rel.core.JoinRelType joinType)
MetadataControllerPOP(PhysicalOperator left, PhysicalOperator right, MetadataControllerContext context)
MetadataHandlerPOP(PhysicalOperator child, MetadataHandlerContext context)
MetadataHashAggPOP(PhysicalOperator child, MetadataAggregateContext context, AggPrelBase.OperatorPhase phase)
MetadataStreamAggPOP(PhysicalOperator child, MetadataAggregateContext context, AggPrelBase.OperatorPhase phase)
NestedLoopJoinPOP(PhysicalOperator left, PhysicalOperator right, org.apache.calcite.rel.core.JoinRelType joinType, LogicalExpression condition)
OrderedMuxExchange(PhysicalOperator child, List<Order.Ordering> orderings)
OrderedPartitionExchange(List<Order.Ordering> orderings, FieldReference ref, PhysicalOperator child, Integer recordsToSample, Integer samplingFactor, Float completionFactor)
OrderedPartitionSender(List<Order.Ordering> orderings, FieldReference ref, PhysicalOperator child, List<MinorFragmentEndpoint> endpoints, int oppositeMajorFragmentId, int sendingWidth, int recordsToSample, int samplingFactor, float completionFactor)
PartitionLimit(PhysicalOperator child, Integer first, Integer last, String partitionColumn)
ProducerConsumer(PhysicalOperator child, int size)
Project(List<NamedExpression> exprs, PhysicalOperator child)
Project(List<NamedExpression> exprs, PhysicalOperator child, boolean outputProj)
RangePartitionExchange(PhysicalOperator child, PartitionFunction partitionFunction)
RangePartitionSender(int oppositeMajorFragmentId, PhysicalOperator child, List<MinorFragmentEndpoint> endpoints, PartitionFunction partitionFunction)
RowKeyJoinPOP(PhysicalOperator left, PhysicalOperator right)
RuntimeFilterPOP(PhysicalOperator child, long identifier)
Screen(PhysicalOperator child, CoordinationProtos.DrillbitEndpoint endpoint)
SelectionVectorRemover(PhysicalOperator child)
SingleMergeExchange(PhysicalOperator child, List<Order.Ordering> orderExpr)
SingleSender(int oppositeMajorFragmentId, int oppositeMinorFragmentId, PhysicalOperator child, CoordinationProtos.DrillbitEndpoint destination) Create a SingleSender which sends data to fragment identified by given MajorFragmentId and MinorFragmentId, and running at given endpoint
SingleSender(int oppositeMajorFragmentId, PhysicalOperator child, CoordinationProtos.DrillbitEndpoint destination) Create a SingleSender which sends data to fragment with MinorFragmentId as 0 in given opposite major fragment.
Sort(PhysicalOperator child, List<Order.Ordering> orderings, boolean reverse)
StatisticsAggregate(PhysicalOperator child, List<String> functions)
StatisticsMerge(PhysicalOperator child, Map<String,String> functions, double samplePercent)
StreamingAggregate(PhysicalOperator child, List<NamedExpression> keys, List<NamedExpression> exprs)
TopN(PhysicalOperator child, List<Order.Ordering> orderings, boolean reverse, int limit)
Trace(PhysicalOperator child, String traceTag)
UnionExchange(PhysicalOperator child)
UnnestPOP(PhysicalOperator child, SchemaPath column, String implicitColumn)
UnorderedDeMuxExchange(PhysicalOperator child, LogicalExpression expr)
UnorderedMuxExchange(PhysicalOperator child)
UnpivotMaps(PhysicalOperator child, List<String> mapFieldNames)
WindowPOP(PhysicalOperator child, List<NamedExpression> withins, List<NamedExpression> aggregations, List<Order.Ordering> orderings, boolean frameUnitsRows, WindowPOP.Bound start, WindowPOP.Bound end)

Constructor parameters in org.apache.drill.exec.physical.config with type arguments of type PhysicalOperator

Constructor and Description
UnionAll(List<PhysicalOperator> children)

Uses of PhysicalOperator in org.apache.drill.exec.physical.impl

Classes in org.apache.drill.exec.physical.impl with type parameters of type PhysicalOperator

Modifier and Type	Interface and Description
interface	BatchCreator<T extends PhysicalOperator>
interface	RootCreator<T extends PhysicalOperator>

Methods in org.apache.drill.exec.physical.impl that return PhysicalOperator

Modifier and Type	Method and Description
static PhysicalOperator	TraceInjector.getExec(FragmentContext context, FragmentRoot root)
PhysicalOperator	TraceInjector.visitOp(PhysicalOperator op, FragmentContext context) Traverse the physical plan and inject the trace operator after every operator.

Methods in org.apache.drill.exec.physical.impl with parameters of type PhysicalOperator

Modifier and Type	Method and Description
RecordBatch	ImplCreator.getRecordBatch(PhysicalOperator op, ExecutorFragmentContext context) Create a RecordBatch and its children for given PhysicalOperator
PhysicalOperator	TraceInjector.visitOp(PhysicalOperator op, FragmentContext context) Traverse the physical plan and inject the trace operator after every operator.

Constructors in org.apache.drill.exec.physical.impl with parameters of type PhysicalOperator

Constructor and Description
BaseRootExec(RootFragmentContext fragmentContext, OperatorContext oContext, PhysicalOperator config)
BaseRootExec(RootFragmentContext fragmentContext, PhysicalOperator config)
ScanBatch(PhysicalOperator subScanConfig, FragmentContext context, List<RecordReader> readers)
ScanBatch(PhysicalOperator subScanConfig, FragmentContext context, List<RecordReader> readerList, boolean isRepeatableScan)

Uses of PhysicalOperator in org.apache.drill.exec.physical.impl.protocol

Constructors in org.apache.drill.exec.physical.impl.protocol with parameters of type PhysicalOperator

Constructor and Description
OperatorRecordBatch(FragmentContext context, PhysicalOperator config, OperatorExec opExec, boolean enableSchemaBatch)

Uses of PhysicalOperator in org.apache.drill.exec.physical.impl.scan.project

Methods in org.apache.drill.exec.physical.impl.scan.project with parameters of type PhysicalOperator

Modifier and Type	Method and Description
OperatorRecordBatch	ScanSchemaOrchestrator.ScanOrchestratorBuilder.buildScanOperator(FragmentContext fragContext, PhysicalOperator pop)

Uses of PhysicalOperator in org.apache.drill.exec.physical.impl.scan.v3

Methods in org.apache.drill.exec.physical.impl.scan.v3 with parameters of type PhysicalOperator

Modifier and Type	Method and Description
OperatorRecordBatch	ScanLifecycleBuilder.buildScanOperator(FragmentContext fragContext, PhysicalOperator pop)

Uses of PhysicalOperator in org.apache.drill.exec.physical.impl.spill

Constructors in org.apache.drill.exec.physical.impl.spill with parameters of type PhysicalOperator

Constructor and Description
SpillSet(DrillConfig config, ExecProtos.FragmentHandle handle, PhysicalOperator popConfig)
SpillSet(FragmentContext context, PhysicalOperator popConfig)

Uses of PhysicalOperator in org.apache.drill.exec.physical.impl.validate

Methods in org.apache.drill.exec.physical.impl.validate that return PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	IteratorValidatorInjector.visitOp(PhysicalOperator op, FragmentContext context) Traverse the physical plan and inject the IteratorValidator operator after every operator.

Methods in org.apache.drill.exec.physical.impl.validate with parameters of type PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	IteratorValidatorInjector.visitOp(PhysicalOperator op, FragmentContext context) Traverse the physical plan and inject the IteratorValidator operator after every operator.

Uses of PhysicalOperator in org.apache.drill.exec.planner

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

Modifier and Type	Method and Description
String	PhysicalPlanReader.writeJson(PhysicalOperator op)

Uses of PhysicalOperator in org.apache.drill.exec.planner.fragment

Methods in org.apache.drill.exec.planner.fragment that return PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	Fragment.getRoot()
PhysicalOperator	Materializer.visitExchange(Exchange exchange, Materializer.IndexedFragmentNode iNode)
PhysicalOperator	Materializer.visitGroupScan(GroupScan groupScan, Materializer.IndexedFragmentNode iNode)
PhysicalOperator	Materializer.visitLateralJoin(LateralJoinPOP op, Materializer.IndexedFragmentNode iNode)
PhysicalOperator	Materializer.visitOp(PhysicalOperator op, Materializer.IndexedFragmentNode iNode)
PhysicalOperator	Materializer.visitRowKeyJoin(RowKeyJoinPOP op, Materializer.IndexedFragmentNode iNode)
PhysicalOperator	Materializer.visitStore(Store store, Materializer.IndexedFragmentNode iNode)
PhysicalOperator	Materializer.visitSubScan(SubScan subScan, Materializer.IndexedFragmentNode value)
PhysicalOperator	Materializer.visitUnnest(UnnestPOP unnest, Materializer.IndexedFragmentNode value)

Methods in org.apache.drill.exec.planner.fragment that return types with arguments of type PhysicalOperator

Modifier and Type	Method and Description
List<org.apache.commons.lang3.tuple.Pair<PhysicalOperator,Long>>	MemoryCalculator.getBufferedOperators(CoordinationProtos.DrillbitEndpoint endpoint)
List<PhysicalOperator>	Fragment.getBufferedOperators(QueryContext queryContext)
protected BiFunction<CoordinationProtos.DrillbitEndpoint,PhysicalOperator,Long>	DefaultQueryParallelizer.getMemory()
BiFunction<CoordinationProtos.DrillbitEndpoint,PhysicalOperator,Long>	QueueQueryParallelizer.getMemory()
protected abstract BiFunction<CoordinationProtos.DrillbitEndpoint,PhysicalOperator,Long>	SimpleParallelizer.getMemory()

Methods in org.apache.drill.exec.planner.fragment with parameters of type PhysicalOperator

Modifier and Type	Method and Description
void	Materializer.IndexedFragmentNode.addAllocation(PhysicalOperator pop)
void	Fragment.addOperator(PhysicalOperator o) Set the given operator as root operator of this fragment.
static List<BitControl.Collector>	SimpleParallelizer.CountRequiredFragments.getCollectors(PhysicalOperator root, boolean enableDynamicFC)
Fragment	MakeFragmentsVisitor.visitOp(PhysicalOperator op, Fragment value)
Void	SimpleParallelizer.CountRequiredFragments.visitOp(PhysicalOperator op, List<BitControl.Collector> collectors)
Void	Fragment.BufferedOpFinder.visitOp(PhysicalOperator op, List<PhysicalOperator> value)
PhysicalOperator	Materializer.visitOp(PhysicalOperator op, Materializer.IndexedFragmentNode iNode)
Void	StatsCollector.visitOp(PhysicalOperator op, Wrapper wrapper)
Void	MemoryCalculator.visitOp(PhysicalOperator op, Wrapper fragment)

Method parameters in org.apache.drill.exec.planner.fragment with type arguments of type PhysicalOperator

Modifier and Type	Method and Description
Void	Fragment.BufferedOpFinder.visitOp(PhysicalOperator op, List<PhysicalOperator> value)

Constructor parameters in org.apache.drill.exec.planner.fragment with type arguments of type PhysicalOperator

Constructor and Description
IndexedFragmentNode(int minorFragmentId, Wrapper info, BiFunction<Wrapper,Integer,CoordinationProtos.DrillbitEndpoint> wrapperToEndpoint, BiFunction<CoordinationProtos.DrillbitEndpoint,PhysicalOperator,Long> memoryReqs)

Uses of PhysicalOperator in org.apache.drill.exec.planner.fragment.contrib

Methods in org.apache.drill.exec.planner.fragment.contrib that return PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	ExchangeRemoverMaterializer.visitExchange(Exchange exchange, Materializer.IndexedFragmentNode iNode)
PhysicalOperator	ExchangeRemoverMaterializer.visitGroupScan(GroupScan groupScan, Materializer.IndexedFragmentNode iNode)
PhysicalOperator	OperatorIdVisitor.visitOp(PhysicalOperator op, Integer parentOpId)
PhysicalOperator	ExchangeRemoverMaterializer.visitOp(PhysicalOperator op, Materializer.IndexedFragmentNode iNode)
PhysicalOperator	ExchangeRemoverMaterializer.visitStore(Store store, Materializer.IndexedFragmentNode iNode)
PhysicalOperator	OperatorIdVisitor.visitSubScan(SubScan subScan, Integer parentOpId)
PhysicalOperator	ExchangeRemoverMaterializer.visitSubScan(SubScan subScan, Materializer.IndexedFragmentNode value)

Methods in org.apache.drill.exec.planner.fragment.contrib with parameters of type PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	OperatorIdVisitor.visitOp(PhysicalOperator op, Integer parentOpId)
PhysicalOperator	ExchangeRemoverMaterializer.visitOp(PhysicalOperator op, Materializer.IndexedFragmentNode iNode)

Uses of PhysicalOperator in org.apache.drill.exec.planner.logical

Methods in org.apache.drill.exec.planner.logical with parameters of type PhysicalOperator

Modifier and Type	Method and Description
Writer	CreateTableEntry.getWriter(PhysicalOperator child)
Writer	FileSystemCreateTableEntry.getWriter(PhysicalOperator child)

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

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

Modifier and Type	Method and Description
PhysicalOperator	PhysicalPlanCreator.addMetadata(Prel originalPrel, PhysicalOperator op)
PhysicalOperator	BroadcastExchangePrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	ComplexToJsonPrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	DirectScanPrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	FilterPrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	FlattenPrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	HashAggPrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	HashJoinPrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	HashToMergeExchangePrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	HashToRandomExchangePrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	LateralJoinPrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	MergeJoinPrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	MetadataControllerPrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	MetadataHandlerPrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	MetadataHashAggPrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	MetadataStreamAggPrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	NestedLoopJoinPrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	OrderedMuxExchangePrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	OrderedPartitionExchangePrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	Prel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	ProducerConsumerPrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	ProjectAllowDupPrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	ProjectPrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	RuntimeFilterPrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	ScreenPrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	SelectionVectorRemoverPrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	SingleMergeExchangePrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	StatsAggPrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	StatsMergePrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	StreamAggPrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	TopNPrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	UnionAllPrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	UnionDistinctPrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	UnionExchangePrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	UnnestPrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	UnorderedDeMuxExchangePrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	UnorderedMuxExchangePrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	UnpivotMapsPrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	WindowPrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	WriterPrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	LimitPrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	ScanPrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	SortPrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	RangePartitionExchangePrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	RowKeyJoinPrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	ValuesPrel.getPhysicalOperator(PhysicalPlanCreator creator)

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

Modifier and Type	Method and Description
PhysicalOperator	PhysicalPlanCreator.addMetadata(Prel originalPrel, PhysicalOperator op)

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

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

Modifier and Type	Method and Description
protected PhysicalOperator	DefaultSqlHandler.convertToPop(Prel prel)

Methods in org.apache.drill.exec.planner.sql.handlers that return types with arguments of type PhysicalOperator

Modifier and Type	Method and Description
static List<PhysicalOperator>	DefaultSqlHandler.getPops(PhysicalOperator root)

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

Modifier and Type	Method and Description
protected PhysicalPlan	DefaultSqlHandler.convertToPlan(PhysicalOperator op)
static List<PhysicalOperator>	DefaultSqlHandler.getPops(PhysicalOperator root)

Uses of PhysicalOperator in org.apache.drill.exec.record

Classes in org.apache.drill.exec.record with type parameters of type PhysicalOperator

Modifier and Type	Class and Description
class	AbstractBinaryRecordBatch<T extends PhysicalOperator>
class	AbstractRecordBatch<T extends PhysicalOperator>
class	AbstractSingleRecordBatch<T extends PhysicalOperator> Implements an AbstractUnaryRecordBatch where the incoming record batch is known at the time of creation
class	AbstractTableFunctionRecordBatch<T extends PhysicalOperator> Implements AbstractUnaryRecodBatch for operators that do not have an incoming record batch available at creation time; the input is typically set up a few steps after creation.
class	AbstractUnaryRecordBatch<T extends PhysicalOperator> Base class for operators that have a single input.

Fields in org.apache.drill.exec.record declared as PhysicalOperator

Modifier and Type	Field and Description
protected T	AbstractRecordBatch.popConfig

Uses of PhysicalOperator in org.apache.drill.exec.store.dfs

Methods in org.apache.drill.exec.store.dfs with parameters of type PhysicalOperator

Modifier and Type	Method and Description
AbstractWriter	FormatPlugin.getWriter(PhysicalOperator child, String location, List<String> partitionColumns)

Uses of PhysicalOperator in org.apache.drill.exec.store.dfs.easy

Classes in org.apache.drill.exec.store.dfs.easy that implement PhysicalOperator

Modifier and Type	Class and Description
class	EasyGroupScan
class	EasySubScan
class	EasyWriter

Methods in org.apache.drill.exec.store.dfs.easy that return PhysicalOperator

Modifier and Type	Method and Description
protected PhysicalOperator	EasyWriter.getNewWithChild(PhysicalOperator child)
PhysicalOperator	EasyGroupScan.getNewWithChildren(List<PhysicalOperator> children)

Methods in org.apache.drill.exec.store.dfs.easy with parameters of type PhysicalOperator

Modifier and Type	Method and Description
protected PhysicalOperator	EasyWriter.getNewWithChild(PhysicalOperator child)
AbstractWriter	EasyFormatPlugin.getWriter(PhysicalOperator child, String location, List<String> partitionColumns)

Method parameters in org.apache.drill.exec.store.dfs.easy with type arguments of type PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	EasyGroupScan.getNewWithChildren(List<PhysicalOperator> children)

Constructors in org.apache.drill.exec.store.dfs.easy with parameters of type PhysicalOperator

Constructor and Description
EasyWriter(PhysicalOperator child, String location, List<String> partitionColumns, EasyFormatPlugin<?> formatPlugin)
EasyWriter(PhysicalOperator child, String location, List<String> partitionColumns, StorageStrategy storageStrategy, StoragePluginConfig storageConfig, FormatPluginConfig formatConfig, StoragePluginRegistry engineRegistry)

Uses of PhysicalOperator in org.apache.drill.exec.store.direct

Classes in org.apache.drill.exec.store.direct that implement PhysicalOperator

Modifier and Type	Class and Description
class	DirectGroupScan
class	DirectSubScan
class	MetadataDirectGroupScan Represents direct scan based on metadata information.

Methods in org.apache.drill.exec.store.direct that return PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	DirectGroupScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	MetadataDirectGroupScan.getNewWithChildren(List<PhysicalOperator> children)

Method parameters in org.apache.drill.exec.store.direct with type arguments of type PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	DirectGroupScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	MetadataDirectGroupScan.getNewWithChildren(List<PhysicalOperator> children)

Uses of PhysicalOperator in org.apache.drill.exec.store.druid

Classes in org.apache.drill.exec.store.druid that implement PhysicalOperator

Modifier and Type	Class and Description
class	DruidGroupScan
class	DruidSubScan A Class containing information to read a single druid data source.

Methods in org.apache.drill.exec.store.druid that return PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	DruidGroupScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	DruidSubScan.getNewWithChildren(List<PhysicalOperator> children)

Methods in org.apache.drill.exec.store.druid that return types with arguments of type PhysicalOperator

Modifier and Type	Method and Description
Iterator<PhysicalOperator>	DruidSubScan.iterator()

Method parameters in org.apache.drill.exec.store.druid with type arguments of type PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	DruidGroupScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	DruidSubScan.getNewWithChildren(List<PhysicalOperator> children)

Uses of PhysicalOperator in org.apache.drill.exec.store.enumerable

Classes in org.apache.drill.exec.store.enumerable that implement PhysicalOperator

Modifier and Type	Class and Description
class	EnumerableGroupScan
class	EnumerableSubScan

Methods in org.apache.drill.exec.store.enumerable that return PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	EnumerableGroupScan.getNewWithChildren(List<PhysicalOperator> children)

Method parameters in org.apache.drill.exec.store.enumerable with type arguments of type PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	EnumerableGroupScan.getNewWithChildren(List<PhysicalOperator> children)

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

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

Modifier and Type	Method and Description
PhysicalOperator	EnumerableIntermediatePrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	EnumerablePrel.getPhysicalOperator(PhysicalPlanCreator creator)

Uses of PhysicalOperator in org.apache.drill.exec.store.hbase

Classes in org.apache.drill.exec.store.hbase that implement PhysicalOperator

Modifier and Type	Class and Description
class	HBaseGroupScan
class	HBaseSubScan Information for reading a single HBase region

Methods in org.apache.drill.exec.store.hbase that return PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	HBaseGroupScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	HBaseSubScan.getNewWithChildren(List<PhysicalOperator> children)

Methods in org.apache.drill.exec.store.hbase that return types with arguments of type PhysicalOperator

Modifier and Type	Method and Description
Iterator<PhysicalOperator>	HBaseSubScan.iterator()

Method parameters in org.apache.drill.exec.store.hbase with type arguments of type PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	HBaseGroupScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	HBaseSubScan.getNewWithChildren(List<PhysicalOperator> children)

Uses of PhysicalOperator in org.apache.drill.exec.store.hive

Classes in org.apache.drill.exec.store.hive that implement PhysicalOperator

Modifier and Type	Class and Description
class	HiveDrillNativeParquetRowGroupScan
class	HiveDrillNativeParquetScan
class	HiveScan
class	HiveSubScan

Methods in org.apache.drill.exec.store.hive that return PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	HiveDrillNativeParquetRowGroupScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	HiveDrillNativeParquetScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	HiveScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	HiveSubScan.getNewWithChildren(List<PhysicalOperator> children)

Methods in org.apache.drill.exec.store.hive that return types with arguments of type PhysicalOperator

Modifier and Type	Method and Description
Iterator<PhysicalOperator>	HiveSubScan.iterator()

Method parameters in org.apache.drill.exec.store.hive with type arguments of type PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	HiveDrillNativeParquetRowGroupScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	HiveDrillNativeParquetScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	HiveScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	HiveSubScan.getNewWithChildren(List<PhysicalOperator> children)

Uses of PhysicalOperator in org.apache.drill.exec.store.http

Classes in org.apache.drill.exec.store.http that implement PhysicalOperator

Modifier and Type	Class and Description
class	HttpGroupScan
class	HttpSubScan

Methods in org.apache.drill.exec.store.http that return PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	HttpGroupScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	HttpSubScan.getNewWithChildren(List<PhysicalOperator> children)

Methods in org.apache.drill.exec.store.http that return types with arguments of type PhysicalOperator

Modifier and Type	Method and Description
Iterator<PhysicalOperator>	HttpSubScan.iterator()

Method parameters in org.apache.drill.exec.store.http with type arguments of type PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	HttpGroupScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	HttpSubScan.getNewWithChildren(List<PhysicalOperator> children)

Uses of PhysicalOperator in org.apache.drill.exec.store.iceberg

Classes in org.apache.drill.exec.store.iceberg that implement PhysicalOperator

Modifier and Type	Class and Description
class	IcebergGroupScan
class	IcebergSubScan

Methods in org.apache.drill.exec.store.iceberg that return PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	IcebergGroupScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	IcebergSubScan.getNewWithChildren(List<PhysicalOperator> children)

Methods in org.apache.drill.exec.store.iceberg that return types with arguments of type PhysicalOperator

Modifier and Type	Method and Description
Iterator<PhysicalOperator>	IcebergSubScan.iterator()

Method parameters in org.apache.drill.exec.store.iceberg with type arguments of type PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	IcebergGroupScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	IcebergSubScan.getNewWithChildren(List<PhysicalOperator> children)

Uses of PhysicalOperator in org.apache.drill.exec.store.iceberg.format

Methods in org.apache.drill.exec.store.iceberg.format with parameters of type PhysicalOperator

Modifier and Type	Method and Description
AbstractWriter	IcebergFormatPlugin.getWriter(PhysicalOperator child, String location, List<String> partitionColumns)

Uses of PhysicalOperator in org.apache.drill.exec.store.ischema

Classes in org.apache.drill.exec.store.ischema that implement PhysicalOperator

Modifier and Type	Class and Description
class	InfoSchemaGroupScan
class	InfoSchemaSubScan

Methods in org.apache.drill.exec.store.ischema that return PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	InfoSchemaGroupScan.getNewWithChildren(List<PhysicalOperator> children)

Method parameters in org.apache.drill.exec.store.ischema with type arguments of type PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	InfoSchemaGroupScan.getNewWithChildren(List<PhysicalOperator> children)

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

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

Modifier and Type	Class and Description
class	JdbcGroupScan
class	JdbcSubScan
class	JdbcWriter

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

Modifier and Type	Method and Description
protected PhysicalOperator	JdbcWriter.getNewWithChild(PhysicalOperator child)
PhysicalOperator	JdbcGroupScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	JdbcIntermediatePrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	JdbcPrel.getPhysicalOperator(PhysicalPlanCreator creator)

Methods in org.apache.drill.exec.store.jdbc with parameters of type PhysicalOperator

Modifier and Type	Method and Description
protected PhysicalOperator	JdbcWriter.getNewWithChild(PhysicalOperator child)

Method parameters in org.apache.drill.exec.store.jdbc with type arguments of type PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	JdbcGroupScan.getNewWithChildren(List<PhysicalOperator> children)

Constructors in org.apache.drill.exec.store.jdbc with parameters of type PhysicalOperator

Constructor and Description
JdbcWriter(PhysicalOperator child, String name, StoragePluginConfig storageConfig, org.apache.calcite.adapter.jdbc.JdbcSchema inner, StoragePluginRegistry engineRegistry)

Uses of PhysicalOperator in org.apache.drill.exec.store.kafka

Classes in org.apache.drill.exec.store.kafka that implement PhysicalOperator

Modifier and Type	Class and Description
class	KafkaGroupScan
class	KafkaSubScan

Methods in org.apache.drill.exec.store.kafka that return PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	KafkaGroupScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	KafkaSubScan.getNewWithChildren(List<PhysicalOperator> children)

Methods in org.apache.drill.exec.store.kafka that return types with arguments of type PhysicalOperator

Modifier and Type	Method and Description
Iterator<PhysicalOperator>	KafkaSubScan.iterator()

Method parameters in org.apache.drill.exec.store.kafka with type arguments of type PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	KafkaGroupScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	KafkaSubScan.getNewWithChildren(List<PhysicalOperator> children)

Uses of PhysicalOperator in org.apache.drill.exec.store.kudu

Classes in org.apache.drill.exec.store.kudu that implement PhysicalOperator

Modifier and Type	Class and Description
class	KuduGroupScan
class	KuduSubScan Information for reading a single Kudu tablet
class	KuduWriter

Methods in org.apache.drill.exec.store.kudu that return PhysicalOperator

Modifier and Type	Method and Description
protected PhysicalOperator	KuduWriter.getNewWithChild(PhysicalOperator child)
PhysicalOperator	KuduSubScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	KuduGroupScan.getNewWithChildren(List<PhysicalOperator> children)

Methods in org.apache.drill.exec.store.kudu that return types with arguments of type PhysicalOperator

Modifier and Type	Method and Description
Iterator<PhysicalOperator>	KuduSubScan.iterator()

Methods in org.apache.drill.exec.store.kudu with parameters of type PhysicalOperator

Modifier and Type	Method and Description
protected PhysicalOperator	KuduWriter.getNewWithChild(PhysicalOperator child)

Method parameters in org.apache.drill.exec.store.kudu with type arguments of type PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	KuduSubScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	KuduGroupScan.getNewWithChildren(List<PhysicalOperator> children)

Constructors in org.apache.drill.exec.store.kudu with parameters of type PhysicalOperator

Constructor and Description
KuduWriter(PhysicalOperator child, String name, StoragePluginConfig storageConfig, StoragePluginRegistry engineRegistry)

Uses of PhysicalOperator in org.apache.drill.exec.store.mapr

Methods in org.apache.drill.exec.store.mapr with parameters of type PhysicalOperator

Modifier and Type	Method and Description
AbstractWriter	TableFormatPlugin.getWriter(PhysicalOperator child, String location, List<String> partitionColumns)

Uses of PhysicalOperator in org.apache.drill.exec.store.mapr.db

Classes in org.apache.drill.exec.store.mapr.db that implement PhysicalOperator

Modifier and Type	Class and Description
class	MapRDBGroupScan
class	MapRDBSubScan
class	RestrictedMapRDBSubScan A RestrictedMapRDBSubScan is intended for skip-scan (as opposed to sequential scan) operations where the set of rowkeys is obtained from a corresponding RowKeyJoin instance

Methods in org.apache.drill.exec.store.mapr.db that return PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	MapRDBSubScan.getNewWithChildren(List<PhysicalOperator> children)

Methods in org.apache.drill.exec.store.mapr.db that return types with arguments of type PhysicalOperator

Modifier and Type	Method and Description
Iterator<PhysicalOperator>	MapRDBSubScan.iterator()

Method parameters in org.apache.drill.exec.store.mapr.db with type arguments of type PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	MapRDBSubScan.getNewWithChildren(List<PhysicalOperator> children)

Uses of PhysicalOperator in org.apache.drill.exec.store.mapr.db.binary

Classes in org.apache.drill.exec.store.mapr.db.binary that implement PhysicalOperator

Modifier and Type	Class and Description
class	BinaryTableGroupScan

Methods in org.apache.drill.exec.store.mapr.db.binary that return PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	BinaryTableGroupScan.getNewWithChildren(List<PhysicalOperator> children)

Method parameters in org.apache.drill.exec.store.mapr.db.binary with type arguments of type PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	BinaryTableGroupScan.getNewWithChildren(List<PhysicalOperator> children)

Uses of PhysicalOperator in org.apache.drill.exec.store.mapr.db.json

Classes in org.apache.drill.exec.store.mapr.db.json that implement PhysicalOperator

Modifier and Type	Class and Description
class	JsonTableGroupScan
class	RestrictedJsonTableGroupScan A RestrictedJsonTableGroupScan encapsulates (along with a subscan) the functionality for doing restricted (i.e skip) scan rather than sequential scan.

Methods in org.apache.drill.exec.store.mapr.db.json that return PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	RestrictedJsonTableGroupScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	JsonTableGroupScan.getNewWithChildren(List<PhysicalOperator> children)

Method parameters in org.apache.drill.exec.store.mapr.db.json with type arguments of type PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	RestrictedJsonTableGroupScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	JsonTableGroupScan.getNewWithChildren(List<PhysicalOperator> children)

Uses of PhysicalOperator in org.apache.drill.exec.store.mapr.streams

Methods in org.apache.drill.exec.store.mapr.streams with parameters of type PhysicalOperator

Modifier and Type	Method and Description
AbstractWriter	StreamsFormatPlugin.getWriter(PhysicalOperator child, String location, List<String> partitionColumns)

Uses of PhysicalOperator in org.apache.drill.exec.store.mock

Classes in org.apache.drill.exec.store.mock that implement PhysicalOperator

Modifier and Type	Class and Description
class	MockGroupScanPOP Describes a "group" scan of a (logical) mock table.
class	MockStorePOP
class	MockSubScanPOP Describes a physical scan operation for the mock data source.

Methods in org.apache.drill.exec.store.mock that return PhysicalOperator

Modifier and Type	Method and Description
protected PhysicalOperator	MockStorePOP.getNewWithChild(PhysicalOperator child)
PhysicalOperator	MockGroupScanPOP.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	MockSubScanPOP.getNewWithChildren(List<PhysicalOperator> children)

Methods in org.apache.drill.exec.store.mock that return types with arguments of type PhysicalOperator

Modifier and Type	Method and Description
Iterator<PhysicalOperator>	MockSubScanPOP.iterator()

Methods in org.apache.drill.exec.store.mock with parameters of type PhysicalOperator

Modifier and Type	Method and Description
protected PhysicalOperator	MockStorePOP.getNewWithChild(PhysicalOperator child)
Store	MockStorePOP.getSpecificStore(PhysicalOperator child, int minorFragmentId)

Method parameters in org.apache.drill.exec.store.mock with type arguments of type PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	MockGroupScanPOP.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	MockSubScanPOP.getNewWithChildren(List<PhysicalOperator> children)

Constructors in org.apache.drill.exec.store.mock with parameters of type PhysicalOperator

Constructor and Description
MockStorePOP(PhysicalOperator child)

Uses of PhysicalOperator in org.apache.drill.exec.store.mongo

Classes in org.apache.drill.exec.store.mongo that implement PhysicalOperator

Modifier and Type	Class and Description
class	MongoGroupScan
class	MongoSubScan

Methods in org.apache.drill.exec.store.mongo that return PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	MongoSubScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	MongoGroupScan.getNewWithChildren(List<PhysicalOperator> children)

Methods in org.apache.drill.exec.store.mongo that return types with arguments of type PhysicalOperator

Modifier and Type	Method and Description
Iterator<PhysicalOperator>	MongoSubScan.iterator()

Method parameters in org.apache.drill.exec.store.mongo with type arguments of type PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	MongoSubScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	MongoGroupScan.getNewWithChildren(List<PhysicalOperator> children)

Uses of PhysicalOperator in org.apache.drill.exec.store.openTSDB

Classes in org.apache.drill.exec.store.openTSDB that implement PhysicalOperator

Modifier and Type	Class and Description
class	OpenTSDBGroupScan
class	OpenTSDBSubScan

Methods in org.apache.drill.exec.store.openTSDB that return PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	OpenTSDBSubScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	OpenTSDBGroupScan.getNewWithChildren(List<PhysicalOperator> children)

Methods in org.apache.drill.exec.store.openTSDB that return types with arguments of type PhysicalOperator

Modifier and Type	Method and Description
Iterator<PhysicalOperator>	OpenTSDBSubScan.iterator()

Method parameters in org.apache.drill.exec.store.openTSDB with type arguments of type PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	OpenTSDBSubScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	OpenTSDBGroupScan.getNewWithChildren(List<PhysicalOperator> children)

Uses of PhysicalOperator in org.apache.drill.exec.store.parquet

Classes in org.apache.drill.exec.store.parquet that implement PhysicalOperator

Modifier and Type	Class and Description
class	AbstractParquetGroupScan
class	AbstractParquetRowGroupScan
class	ParquetGroupScan
class	ParquetRowGroupScan
class	ParquetWriter

Methods in org.apache.drill.exec.store.parquet that return PhysicalOperator

Modifier and Type	Method and Description
protected PhysicalOperator	ParquetWriter.getNewWithChild(PhysicalOperator child)
PhysicalOperator	ParquetRowGroupScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	ParquetGroupScan.getNewWithChildren(List<PhysicalOperator> children)

Methods in org.apache.drill.exec.store.parquet that return types with arguments of type PhysicalOperator

Modifier and Type	Method and Description
Iterator<PhysicalOperator>	AbstractParquetRowGroupScan.iterator()

Methods in org.apache.drill.exec.store.parquet with parameters of type PhysicalOperator

Modifier and Type	Method and Description
protected PhysicalOperator	ParquetWriter.getNewWithChild(PhysicalOperator child)
AbstractWriter	ParquetFormatPlugin.getWriter(PhysicalOperator child, String location, List<String> partitionColumns)

Method parameters in org.apache.drill.exec.store.parquet with type arguments of type PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	ParquetRowGroupScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	ParquetGroupScan.getNewWithChildren(List<PhysicalOperator> children)

Constructors in org.apache.drill.exec.store.parquet with parameters of type PhysicalOperator

Constructor and Description
ParquetWriter(PhysicalOperator child, String location, List<String> partitionColumns, ParquetFormatPlugin formatPlugin)
ParquetWriter(PhysicalOperator child, String location, List<String> partitionColumns, StorageStrategy storageStrategy, StoragePluginConfig storageConfig, StoragePluginRegistry engineRegistry)

Uses of PhysicalOperator in org.apache.drill.exec.store.phoenix

Classes in org.apache.drill.exec.store.phoenix that implement PhysicalOperator

Modifier and Type	Class and Description
class	PhoenixGroupScan
class	PhoenixSubScan

Methods in org.apache.drill.exec.store.phoenix that return PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	PhoenixGroupScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	PhoenixSubScan.getNewWithChildren(List<PhysicalOperator> children)

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

Modifier and Type	Method and Description
Iterator<PhysicalOperator>	PhoenixSubScan.iterator()

Method parameters in org.apache.drill.exec.store.phoenix with type arguments of type PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	PhoenixGroupScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	PhoenixSubScan.getNewWithChildren(List<PhysicalOperator> children)

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

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

Modifier and Type	Method and Description
PhysicalOperator	PhoenixIntermediatePrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	PhoenixPrel.getPhysicalOperator(PhysicalPlanCreator creator)

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

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

Modifier and Type	Method and Description
PhysicalOperator	PluginIntermediatePrel.getPhysicalOperator(PhysicalPlanCreator creator)
PhysicalOperator	PluginPrel.getPhysicalOperator(PhysicalPlanCreator creator)

Uses of PhysicalOperator in org.apache.drill.exec.store.splunk

Classes in org.apache.drill.exec.store.splunk that implement PhysicalOperator

Modifier and Type	Class and Description
class	SplunkGroupScan
class	SplunkSubScan

Methods in org.apache.drill.exec.store.splunk that return PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	SplunkGroupScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	SplunkSubScan.getNewWithChildren(List<PhysicalOperator> children)

Methods in org.apache.drill.exec.store.splunk that return types with arguments of type PhysicalOperator

Modifier and Type	Method and Description
Iterator<PhysicalOperator>	SplunkSubScan.iterator()

Method parameters in org.apache.drill.exec.store.splunk with type arguments of type PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	SplunkGroupScan.getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator	SplunkSubScan.getNewWithChildren(List<PhysicalOperator> children)

Uses of PhysicalOperator in org.apache.drill.exec.store.sys

Classes in org.apache.drill.exec.store.sys that implement PhysicalOperator

Modifier and Type	Class and Description
class	SystemTableScan

Methods in org.apache.drill.exec.store.sys that return PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	SystemTableScan.getNewWithChildren(List<PhysicalOperator> children)

Method parameters in org.apache.drill.exec.store.sys with type arguments of type PhysicalOperator

Modifier and Type	Method and Description
PhysicalOperator	SystemTableScan.getNewWithChildren(List<PhysicalOperator> children)

Uses of PhysicalOperator in org.apache.drill.exec.util

Methods in org.apache.drill.exec.util that return types with arguments of type PhysicalOperator

Modifier and Type	Method and Description
static List<PhysicalOperator>	MemoryAllocationUtilities.getBufferedOperators(List<PhysicalOperator> operators, QueryContext queryContext)

Method parameters in org.apache.drill.exec.util with type arguments of type PhysicalOperator

Modifier and Type	Method and Description
static List<PhysicalOperator>	MemoryAllocationUtilities.getBufferedOperators(List<PhysicalOperator> operators, QueryContext queryContext)
static void	MemoryAllocationUtilities.setupBufferedOpsMemoryAllocations(boolean planHasMemory, List<PhysicalOperator> bufferedOperators, QueryContext queryContext) Helper method to setup Memory Allocations

Uses of PhysicalOperator in org.apache.drill.exec.work.filter

Methods in org.apache.drill.exec.work.filter with parameters of type PhysicalOperator

Modifier and Type	Method and Description
Void	RuntimeFilterRouter.RuntimeFilterParallelismCollector.visitOp(PhysicalOperator op, org.apache.drill.exec.work.filter.RuntimeFilterRouter.RFHelperHolder holder)

Uses of PhysicalOperator in org.apache.drill.exec.work.foreman.rm

Methods in org.apache.drill.exec.work.foreman.rm with parameters of type PhysicalOperator

Modifier and Type	Method and Description
Void	ThrottledResourceManager.QueuedResourceAllocator.BufferedOpFinder.visitOp(PhysicalOperator op, List<PhysicalOperator> value)

Method parameters in org.apache.drill.exec.work.foreman.rm with type arguments of type PhysicalOperator

Modifier and Type	Method and Description
Void	ThrottledResourceManager.QueuedResourceAllocator.BufferedOpFinder.visitOp(PhysicalOperator op, List<PhysicalOperator> value)