public class AllGather extends java.lang.Object implements DataFlowOperation
| Modifier and Type | Field and Description |
|---|---|
protected java.util.Set<java.lang.Integer> |
sources |
| Constructor and Description |
|---|
AllGather(Config config,
TWSChannel chnl,
LogicalPlan instancePlan,
java.util.Set<java.lang.Integer> sources,
java.util.Set<java.lang.Integer> destination,
int middleTask,
BulkReceiver finalRecv,
MessageType type,
int redEdge,
int broadEdge,
boolean stream,
MessageSchema messageSchema) |
| Modifier and Type | Method and Description |
|---|---|
void |
close()
Close the operation
|
void |
finish(int source)
If this is a larger transfer of dataflow style, we need to finish
|
LogicalPlan |
getLogicalPlan()
Task plan associated with this operation
|
java.lang.String |
getUniqueId()
Returns a unique id for this operation.
|
boolean |
isComplete()
Weather the operation doesn't have any pending sends or receives
|
boolean |
progress()
Progress the pending dataflow operations
|
void |
reset()
Reset and get the operation to initial state
|
boolean |
send(int source,
java.lang.Object message,
int flags)
Send a send message, this call will work asynchronously
|
boolean |
send(int source,
java.lang.Object message,
int flags,
int target)
Send the message on a specific path
|
boolean |
sendPartial(int source,
java.lang.Object message,
int flags)
Use this to inject partial results in a distributed dataflow operation
|
boolean |
sendPartial(int source,
java.lang.Object message,
int flags,
int target)
Send partial message on a specific path
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetDataType, getKeyType, getReceiveDataType, getReceiveKeyType, getSources, getTargets, isDelegateCompletepublic AllGather(Config config, TWSChannel chnl, LogicalPlan instancePlan, java.util.Set<java.lang.Integer> sources, java.util.Set<java.lang.Integer> destination, int middleTask, BulkReceiver finalRecv, MessageType type, int redEdge, int broadEdge, boolean stream, MessageSchema messageSchema)
public boolean sendPartial(int source,
java.lang.Object message,
int flags)
DataFlowOperationsendPartial in interface DataFlowOperationmessage - messagepublic boolean send(int source,
java.lang.Object message,
int flags)
DataFlowOperationsend in interface DataFlowOperationsource - source taskmessage - message as a generic objectpublic boolean send(int source,
java.lang.Object message,
int flags,
int target)
DataFlowOperationsend in interface DataFlowOperationsource - source taskmessage - a generic java objecttarget - target taskpublic boolean sendPartial(int source,
java.lang.Object message,
int flags,
int target)
DataFlowOperationsendPartial in interface DataFlowOperationsource - the sourcemessage - message as a generic objecttarget - the final targetpublic boolean progress()
DataFlowOperationprogress in interface DataFlowOperationpublic boolean isComplete()
DataFlowOperationisComplete in interface DataFlowOperationpublic void close()
DataFlowOperationclose in interface DataFlowOperationpublic void reset()
DataFlowOperationreset in interface DataFlowOperationpublic void finish(int source)
DataFlowOperationfinish in interface DataFlowOperationpublic LogicalPlan getLogicalPlan()
DataFlowOperationgetLogicalPlan in interface DataFlowOperationpublic java.lang.String getUniqueId()
DataFlowOperationgetUniqueId in interface DataFlowOperation