public class OrderedPartitionSender extends AbstractSender
Modifier and Type | Field and Description |
---|---|
static String |
OPERATOR_TYPE |
destinations, oppositeMajorFragmentId
child
INIT_ALLOCATION, initialAllocation, MAX_ALLOCATION, maxAllocation, userName
Constructor and Description |
---|
OrderedPartitionSender(List<Order.Ordering> orderings,
FieldReference ref,
PhysicalOperator child,
List<MinorFragmentEndpoint> endpoints,
int oppositeMajorFragmentId,
int sendingWidth,
int recordsToSample,
int samplingFactor,
float completionFactor) |
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.
|
float |
getCompletionFactor() |
protected PhysicalOperator |
getNewWithChild(PhysicalOperator child) |
String |
getOperatorType() |
List<Order.Ordering> |
getOrderings() |
int |
getRecordsToSample() |
FieldReference |
getRef() |
int |
getSamplingFactor() |
int |
getSendingWidth() |
String |
toString() |
getDestinations, getOppositeMajorFragmentId
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 OrderedPartitionSender(List<Order.Ordering> orderings, FieldReference ref, PhysicalOperator child, List<MinorFragmentEndpoint> endpoints, int oppositeMajorFragmentId, int sendingWidth, int recordsToSample, int samplingFactor, float completionFactor)
public int getSendingWidth()
public List<Order.Ordering> getOrderings()
public FieldReference getRef()
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 AbstractSender
E extends Throwable
protected PhysicalOperator getNewWithChild(PhysicalOperator child)
getNewWithChild
in class AbstractSingle
public int getRecordsToSample()
public int getSamplingFactor()
public float getCompletionFactor()
public String getOperatorType()
Copyright © 1970 The Apache Software Foundation. All rights reserved.