public abstract class AbstractReceiver extends AbstractBase implements Receiver
INIT_ALLOCATION, initialAllocation, MAX_ALLOCATION, maxAllocation, userName
Constructor and Description |
---|
AbstractReceiver(int oppositeMajorFragmentId,
List<MinorFragmentEndpoint> senders,
boolean spooling) |
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.
|
PhysicalOperator |
getNewWithChildren(List<PhysicalOperator> children)
Regenerate with this node with a new set of children.
|
int |
getNumSenders() |
int |
getOppositeMajorFragmentId() |
List<MinorFragmentEndpoint> |
getProvidingEndpoints()
A receiver is expecting streams from one or more providing endpoints.
|
boolean |
isSpooling() |
Iterator<PhysicalOperator> |
iterator() |
accept, getCost, getInitialAllocation, getMaxAllocation, getOperatorId, getSVMode, getUserName, isBufferedOperator, isExecutable, setCost, setMaxAllocation, setOperatorId
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
supportsOutOfOrderExchange
getCost, getInitialAllocation, getMaxAllocation, getOperatorId, getOperatorType, getSVMode, getUserName, isBufferedOperator, isExecutable, setCost, setMaxAllocation, setOperatorId
accept
forEach, spliterator
public AbstractReceiver(int oppositeMajorFragmentId, List<MinorFragmentEndpoint> senders, boolean spooling)
oppositeMajorFragmentId
- MajorFragmentId of fragments that are sending data to this receiver.senders
- List of sender MinorFragmentEndpoints each containing sender MinorFragmentId and Drillbit endpoint
where it is running.public Iterator<PhysicalOperator> iterator()
iterator
in interface Iterable<PhysicalOperator>
public <T,X,E extends Throwable> T accept(PhysicalVisitor<T,X,E> physicalVisitor, X value) throws E extends Throwable
PhysicalOperator
accept
in interface PhysicalOperator
E extends Throwable
public final PhysicalOperator getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator
getNewWithChildren
in interface PhysicalOperator
public int getOppositeMajorFragmentId()
getOppositeMajorFragmentId
in interface Receiver
public List<MinorFragmentEndpoint> getProvidingEndpoints()
Receiver
getProvidingEndpoints
in interface Receiver
public int getNumSenders()
public boolean isSpooling()
isSpooling
in interface Receiver
Copyright © 1970 The Apache Software Foundation. All rights reserved.