public class SingleSender 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 |
---|
SingleSender(int oppositeMajorFragmentId,
int oppositeMinorFragmentId,
PhysicalOperator child,
CoordinationProtos.DrillbitEndpoint destination)
Create a SingleSender which sends data to fragment identified by given MajorFragmentId and MinorFragmentId,
and running at given endpoint
|
SingleSender(int oppositeMajorFragmentId,
PhysicalOperator child,
CoordinationProtos.DrillbitEndpoint destination)
Create a SingleSender which sends data to fragment with MinorFragmentId as 0 in given opposite major
fragment.
|
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.
|
CoordinationProtos.DrillbitEndpoint |
getDestination() |
List<MinorFragmentEndpoint> |
getDestinations()
Get the list of destination endpoints that this Sender will be communicating with.
|
protected PhysicalOperator |
getNewWithChild(PhysicalOperator child) |
String |
getOperatorType() |
int |
getOppositeMinorFragmentId() |
getOppositeMajorFragmentId
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 static final String OPERATOR_TYPE
public SingleSender(int oppositeMajorFragmentId, int oppositeMinorFragmentId, PhysicalOperator child, CoordinationProtos.DrillbitEndpoint destination)
oppositeMajorFragmentId
- MajorFragmentId of the receiver fragment.oppositeMinorFragmentId
- MinorFragmentId of the receiver fragment.child
- Child operatordestination
- Drillbit endpoint where the receiver fragment is running.public SingleSender(int oppositeMajorFragmentId, PhysicalOperator child, CoordinationProtos.DrillbitEndpoint destination)
oppositeMajorFragmentId
- MajorFragmentId of the receiver fragment.child
- Child operatordestination
- Drillbit endpoint where the receiver fragment is running.public List<MinorFragmentEndpoint> getDestinations()
Sender
getDestinations
in interface Sender
getDestinations
in class AbstractSender
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 AbstractSender
E extends Throwable
public CoordinationProtos.DrillbitEndpoint getDestination()
public int getOppositeMinorFragmentId()
public String getOperatorType()
Copyright © 1970 The Apache Software Foundation. All rights reserved.