public class MockStorePOP extends AbstractStore
child
INIT_ALLOCATION, initialAllocation, MAX_ALLOCATION, maxAllocation, userName
Constructor and Description |
---|
MockStorePOP(PhysicalOperator child) |
Modifier and Type | Method and Description |
---|---|
void |
applyAssignments(List<CoordinationProtos.DrillbitEndpoint> endpoints)
Inform the Store node about the actual decided DrillbitEndpoint assignments desired for storage purposes.
|
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.
|
accept, getDistributionAffinity
getChild, getNewWithChildren, iterator
accept, getCost, getInitialAllocation, getMaxAllocation, getOperatorId, getSVMode, getUserName, isBufferedOperator, isExecutable, setCost, setMaxAllocation, setOperatorId
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getCost, getInitialAllocation, getMaxAllocation, getNewWithChildren, getOperatorId, getSVMode, getUserName, isBufferedOperator, isExecutable, setCost, setMaxAllocation, setOperatorId
accept
forEach, iterator, spliterator
public MockStorePOP(PhysicalOperator child)
public int getMaxWidth()
Store
public List<EndpointAffinity> getOperatorAffinity()
HasAffinity
public void applyAssignments(List<CoordinationProtos.DrillbitEndpoint> endpoints)
Store
endpoints
- The list of endpoints that this Store node are going to be executed on.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.protected PhysicalOperator getNewWithChild(PhysicalOperator child)
getNewWithChild
in class AbstractSingle
public String getOperatorType()
Copyright © 1970 The Apache Software Foundation. All rights reserved.