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()
BaseOperation
isComplete
in class BaseOperation
public void finish(int src)
BaseOperation
finish
in class BaseOperation
src
- the source that is endingpublic boolean progress()
BaseOperation
progress
in class BaseOperation
public void close()
close
in class BaseOperation
public void reset()
BaseOperation
reset
in class BaseOperation
public boolean progressChannel()
BaseOperation
progressChannel
in class BaseOperation
public boolean sendBarrier(int src, byte[] barrierId)
sendBarrier
in class BaseOperation
public void waitForCompletion()
BaseOperation
waitForCompletion
in class BaseOperation