public class Screen extends AbstractStore
Modifier and Type | Field and Description |
---|---|
static String |
OPERATOR_TYPE |
child
INIT_ALLOCATION, initialAllocation, MAX_ALLOCATION, maxAllocation, userName
Constructor and Description |
---|
Screen(PhysicalOperator child,
CoordinationProtos.DrillbitEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
<T,X,E extends Throwable> |
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() |
getChild, getNewWithChildren, iterator
accept, getCost, getInitialAllocation, getMaxAllocation, getOperatorId, getSVMode, getUserName, isBufferedOperator, isExecutable, setCost, setMaxAllocation, setOperatorId
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getCost, getInitialAllocation, getMaxAllocation, getNewWithChildren, getOperatorId, getSVMode, getUserName, isBufferedOperator, isExecutable, setCost, setMaxAllocation, setOperatorId
accept
forEach, iterator, spliterator
public static final String OPERATOR_TYPE
public Screen(PhysicalOperator child, CoordinationProtos.DrillbitEndpoint endpoint)
public List<EndpointAffinity> getOperatorAffinity()
HasAffinity
public int getMaxWidth()
Store
public void applyAssignments(List<CoordinationProtos.DrillbitEndpoint> endpoints) throws PhysicalOperatorSetupException
Store
endpoints
- The list of endpoints that this Store node are going to be executed on.PhysicalOperatorSetupException
public Store getSpecificStore(PhysicalOperator child, int minorFragmentId)
Store
child
- The child operator that this operator will consume from.minorFragmentId
- The particular minor fragment id associated with this particular fragment materialization.public CoordinationProtos.DrillbitEndpoint getEndpoint()
protected PhysicalOperator getNewWithChild(PhysicalOperator child)
getNewWithChild
in class AbstractSingle
public <T,X,E extends Throwable> T accept(PhysicalVisitor<T,X,E> physicalVisitor, X value) throws E extends Throwable
PhysicalOperator
accept
in interface PhysicalOperator
accept
in class AbstractStore
E extends Throwable
public String getOperatorType()
public DistributionAffinity getDistributionAffinity()
HasAffinity
getDistributionAffinity
in interface HasAffinity
getDistributionAffinity
in class AbstractStore
Copyright © 1970 The Apache Software Foundation. All rights reserved.