Class BroadcastSender
java.lang.Object
org.apache.drill.exec.physical.base.AbstractBase
org.apache.drill.exec.physical.base.AbstractSingle
org.apache.drill.exec.physical.base.AbstractSender
org.apache.drill.exec.physical.config.BroadcastSender
- All Implemented Interfaces:
Iterable<PhysicalOperator>
,GraphValue<PhysicalOperator>
,FragmentLeaf
,FragmentRoot
,PhysicalOperator
,Sender
-
Field Summary
Fields inherited from class org.apache.drill.exec.physical.base.AbstractSender
destinations, oppositeMajorFragmentId
Fields inherited from class org.apache.drill.exec.physical.base.AbstractSingle
child
Fields inherited from class org.apache.drill.exec.physical.base.AbstractBase
INIT_ALLOCATION, initialAllocation, MAX_ALLOCATION, maxAllocation, userName
-
Constructor Summary
ConstructorDescriptionBroadcastSender
(int oppositeMajorFragmentId, PhysicalOperator child, List<MinorFragmentEndpoint> destinations) -
Method Summary
Modifier and TypeMethodDescription<T,
X, E extends Throwable>
Taccept
(PhysicalVisitor<T, X, E> physicalVisitor, X value) Provides capability to build a set of output based on traversing a query graph tree.protected PhysicalOperator
getNewWithChild
(PhysicalOperator child) Methods inherited from class org.apache.drill.exec.physical.base.AbstractSender
getDestinations, getOppositeMajorFragmentId
Methods inherited from class org.apache.drill.exec.physical.base.AbstractSingle
getChild, getNewWithChildren, iterator
Methods inherited from class org.apache.drill.exec.physical.base.AbstractBase
accept, getCost, getInitialAllocation, getMaxAllocation, getOperatorId, getSVMode, getUserName, isBufferedOperator, isExecutable, setCost, setMaxAllocation, setOperatorId
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.apache.drill.common.graph.GraphValue
accept
Methods inherited from interface java.lang.Iterable
forEach, iterator, spliterator
Methods inherited from interface org.apache.drill.exec.physical.base.PhysicalOperator
getCost, getInitialAllocation, getMaxAllocation, getNewWithChildren, getOperatorId, getSVMode, getUserName, isBufferedOperator, isExecutable, setCost, setMaxAllocation, setOperatorId
-
Field Details
-
OPERATOR_TYPE
- See Also:
-
-
Constructor Details
-
BroadcastSender
public BroadcastSender(int oppositeMajorFragmentId, PhysicalOperator child, List<MinorFragmentEndpoint> destinations)
-
-
Method Details
-
getNewWithChild
- Specified by:
getNewWithChild
in classAbstractSingle
-
accept
public <T,X, T acceptE extends Throwable> (PhysicalVisitor<T, X, throws EE> physicalVisitor, X value) Description copied from interface:PhysicalOperator
Provides capability to build a set of output based on traversing a query graph tree.- Specified by:
accept
in interfacePhysicalOperator
- Overrides:
accept
in classAbstractSender
- Throws:
E extends Throwable
-
getOperatorType
-