public class BTPartition extends BaseOperation
channel, op| Constructor and Description |
|---|
BTPartition(Communicator comm,
IWorkerController controller,
java.util.Set<java.lang.Integer> sources,
java.util.Set<java.lang.Integer> targets,
LogicalPlan plan,
DestinationSelector selector,
java.util.List<java.lang.Integer> indexes,
Schema schema,
BulkReceiver receiver,
RootAllocator allocator,
java.lang.String name) |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
void |
finish(int src)
Indicate the end of the communication
|
boolean |
insert(int source,
Table t) |
boolean |
isComplete()
Weather we have messages pending
|
boolean |
progress()
Progress the operation, if not called, messages will not be processed
|
boolean |
progressChannel()
Progress the channel and the operation
|
void |
reset()
Clean the operation, this doesn't close it
|
boolean |
sendBarrier(int src,
byte[] barrierId) |
void |
waitForCompletion()
Wait for the operation to complete
|
public BTPartition(Communicator comm, IWorkerController controller, java.util.Set<java.lang.Integer> sources, java.util.Set<java.lang.Integer> targets, LogicalPlan plan, DestinationSelector selector, java.util.List<java.lang.Integer> indexes, Schema schema, BulkReceiver receiver, RootAllocator allocator, java.lang.String name)
public boolean insert(int source,
Table t)
public boolean isComplete()
BaseOperationisComplete in class BaseOperationpublic void finish(int src)
BaseOperationfinish in class BaseOperationsrc - the source that is endingpublic boolean progress()
BaseOperationprogress in class BaseOperationpublic void close()
close in class BaseOperationpublic void reset()
BaseOperationreset in class BaseOperationpublic boolean progressChannel()
BaseOperationprogressChannel in class BaseOperationpublic boolean sendBarrier(int src,
byte[] barrierId)
sendBarrier in class BaseOperationpublic void waitForCompletion()
BaseOperationwaitForCompletion in class BaseOperation