Class Screen
java.lang.Object
org.apache.drill.exec.physical.base.AbstractBase
org.apache.drill.exec.physical.base.AbstractSingle
org.apache.drill.exec.physical.base.AbstractStore
org.apache.drill.exec.physical.config.Screen
- All Implemented Interfaces:
Iterable<PhysicalOperator>
,GraphValue<PhysicalOperator>
,FragmentLeaf
,FragmentRoot
,HasAffinity
,PhysicalOperator
,Root
,Store
-
Field Summary
Fields inherited from class org.apache.drill.exec.physical.base.AbstractSingle
child
Fields inherited from class org.apache.drill.exec.physical.base.AbstractBase
INIT_ALLOCATION, initialAllocation, MAX_ALLOCATION, maxAllocation, userName
-
Constructor Summary
ConstructorDescriptionScreen
(PhysicalOperator child, CoordinationProtos.DrillbitEndpoint endpoint) -
Method Summary
Modifier and TypeMethodDescription<T,
X, E extends Throwable>
Taccept
(PhysicalVisitor<T, X, E> physicalVisitor, X value) Provides capability to build a set of output based on traversing a query graph tree.void
applyAssignments
(List<CoordinationProtos.DrillbitEndpoint> endpoints) Inform the Store node about the actual decided DrillbitEndpoint assignments desired for storage purposes.Get distribution affinity which describes the parallelization strategy of the operator.int
The maximum allowable width for the Store operation.protected PhysicalOperator
getNewWithChild
(PhysicalOperator child) Get the list of Endpoints with associated affinities that this operator has preference for.getSpecificStore
(PhysicalOperator child, int minorFragmentId) Provides full materialized Store operators for execution purposes.toString()
Methods inherited from class org.apache.drill.exec.physical.base.AbstractSingle
getChild, getNewWithChildren, iterator
Methods inherited from class org.apache.drill.exec.physical.base.AbstractBase
accept, getCost, getInitialAllocation, getMaxAllocation, getOperatorId, getSVMode, getUserName, isBufferedOperator, isExecutable, setCost, setMaxAllocation, setOperatorId
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
Methods inherited from interface org.apache.drill.common.graph.GraphValue
accept
Methods inherited from interface java.lang.Iterable
forEach, iterator, spliterator
Methods inherited from interface org.apache.drill.exec.physical.base.PhysicalOperator
getCost, getInitialAllocation, getMaxAllocation, getNewWithChildren, getOperatorId, getSVMode, getUserName, isBufferedOperator, isExecutable, setCost, setMaxAllocation, setOperatorId
-
Field Details
-
OPERATOR_TYPE
- See Also:
-
-
Constructor Details
-
Screen
-
-
Method Details
-
getOperatorAffinity
Description copied from interface:HasAffinity
Get the list of Endpoints with associated affinities that this operator has preference for.- Returns:
- List of EndpointAffinity objects.
-
getMaxWidth
public int getMaxWidth()Description copied from interface:Store
The maximum allowable width for the Store operation. In some cases, a store operation has a limited number of parallelizations that it can support. For example, a Screen return cannot be parallelized at all. In this case, a maxWidth value of 1 will be returned. In the case that there is no limit for parallelization, this method should return Integer.MAX_VALUE.- Returns:
- The maximum allowable width for the Store operation.
-
applyAssignments
public void applyAssignments(List<CoordinationProtos.DrillbitEndpoint> endpoints) throws PhysicalOperatorSetupException Description copied from interface:Store
Inform the Store node about the actual decided DrillbitEndpoint assignments desired for storage purposes. This is a precursor to the execution planner running a set of getSpecificStore() method calls for full Store node materialization.- Parameters:
endpoints
- The list of endpoints that this Store node are going to be executed on.- Throws:
PhysicalOperatorSetupException
-
getSpecificStore
Description copied from interface:Store
Provides full materialized Store operators for execution purposes.- Parameters:
child
- The child operator that this operator will consume from.minorFragmentId
- The particular minor fragment id associated with this particular fragment materialization.- Returns:
- A materialized Store Operator.
-
getEndpoint
-
toString
-
getNewWithChild
- Specified by:
getNewWithChild
in classAbstractSingle
-
accept
public <T,X, T acceptE extends Throwable> (PhysicalVisitor<T, X, throws EE> physicalVisitor, X value) Description copied from interface:PhysicalOperator
Provides capability to build a set of output based on traversing a query graph tree.- Specified by:
accept
in interfacePhysicalOperator
- Overrides:
accept
in classAbstractStore
- Throws:
E extends Throwable
-
getOperatorType
-
getDistributionAffinity
Description copied from interface:HasAffinity
Get distribution affinity which describes the parallelization strategy of the operator.- Specified by:
getDistributionAffinity
in interfaceHasAffinity
- Overrides:
getDistributionAffinity
in classAbstractStore
-