public class UnorderedReceiver extends AbstractReceiver
Modifier and Type | Field and Description |
---|---|
static String |
OPERATOR_TYPE |
INIT_ALLOCATION, initialAllocation, MAX_ALLOCATION, maxAllocation, userName
Constructor and Description |
---|
UnorderedReceiver(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.
|
String |
getOperatorType() |
boolean |
supportsOutOfOrderExchange()
Whether or not this receive supports out of order exchange.
|
getNewWithChildren, getNumSenders, getOppositeMajorFragmentId, getProvidingEndpoints, isSpooling, 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, getOperatorId, getSVMode, getUserName, isBufferedOperator, isExecutable, setCost, setMaxAllocation, setOperatorId
accept
forEach, spliterator
public static final String OPERATOR_TYPE
public UnorderedReceiver(int oppositeMajorFragmentId, List<MinorFragmentEndpoint> senders, boolean spooling)
public boolean supportsOutOfOrderExchange()
Receiver
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 AbstractReceiver
E extends Throwable
public String getOperatorType()
Copyright © 1970 The Apache Software Foundation. All rights reserved.