org.apache.drill.exec.physical.config

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

public class Screen
extends AbstractStore

Field Summary

Fields

Modifier and Type	Field and Description
static String	OPERATOR_TYPE

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

Constructor Summary

Constructors

Constructor and Description
Screen(PhysicalOperator child, CoordinationProtos.DrillbitEndpoint endpoint)

Method Summary

Modifier and Type	Method and Description
<T,X,E extends Throwable> T	accept(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.
DistributionAffinity	getDistributionAffinity() Get distribution affinity which describes the parallelization strategy of the operator.
CoordinationProtos.DrillbitEndpoint	getEndpoint()
int	getMaxWidth() The maximum allowable width for the Store operation.
protected PhysicalOperator	getNewWithChild(PhysicalOperator child)
List<EndpointAffinity>	getOperatorAffinity() Get the list of Endpoints with associated affinities that this operator has preference for.
String	getOperatorType()
Store	getSpecificStore(PhysicalOperator child, int minorFragmentId) Provides full materialized Store operators for execution purposes.
String	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.exec.physical.base.Store

getChild

Methods inherited from interface org.apache.drill.exec.physical.base.PhysicalOperator

getCost, getInitialAllocation, getMaxAllocation, getNewWithChildren, getOperatorId, getSVMode, getUserName, isBufferedOperator, isExecutable, setCost, setMaxAllocation, setOperatorId

Methods inherited from interface org.apache.drill.common.graph.GraphValue

accept

Methods inherited from interface java.lang.Iterable

forEach, iterator, spliterator

Field Detail

OPERATOR_TYPE

public static final String OPERATOR_TYPE

See Also:

Constant Field Values

Constructor Detail

Screen

public Screen(PhysicalOperator child,
              CoordinationProtos.DrillbitEndpoint endpoint)

Method Detail

getOperatorAffinity

public List<EndpointAffinity> 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

public Store getSpecificStore(PhysicalOperator child,
                              int minorFragmentId)

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

public CoordinationProtos.DrillbitEndpoint getEndpoint()

toString

public String toString()

Overrides:

toString in class Object

getNewWithChild

protected PhysicalOperator getNewWithChild(PhysicalOperator child)

Specified by:

getNewWithChild in class AbstractSingle

accept

public <T,X,E extends Throwable> T accept(PhysicalVisitor<T,X,E> physicalVisitor,
                                          X value)
                                   throws E extends Throwable

Description copied from interface: PhysicalOperator

Provides capability to build a set of output based on traversing a query graph tree.

Specified by:

accept in interface PhysicalOperator

Overrides:

accept in class AbstractStore

Throws:

E extends Throwable

getOperatorType

public String getOperatorType()

getDistributionAffinity

public DistributionAffinity getDistributionAffinity()

Description copied from interface: HasAffinity

Get distribution affinity which describes the parallelization strategy of the operator.

Specified by:

getDistributionAffinity in interface HasAffinity

Overrides:

getDistributionAffinity in class AbstractStore