edu.iu.dsc.tws.comms.table.ops

Class STPartition

java.lang.Object

edu.iu.dsc.tws.api.comms.BaseOperation

edu.iu.dsc.tws.comms.table.ops.STPartition

public class STPartition
extends BaseOperation

Field Summary

Fields inherited from class edu.iu.dsc.tws.api.comms.BaseOperation

channel, op

Constructor Summary

Constructors

Constructor and Description
STPartition(Communicator comm, IWorkerController controller, LogicalPlanBuilder builder, DestinationSelector selector, java.util.List<java.lang.Integer> indexes, Schema schema, ArrowCallback receiver, RootAllocator allocator) Create the base operation
STPartition(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, ArrowCallback receiver, RootAllocator allocator) Create the base operation
STPartition(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, ArrowCallback receiver, RootAllocator allocator, java.lang.String name) Create the base operation

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

STPartition

public STPartition(Communicator comm,
                   IWorkerController controller,
                   LogicalPlanBuilder builder,
                   DestinationSelector selector,
                   java.util.List<java.lang.Integer> indexes,
                   Schema schema,
                   ArrowCallback receiver,
                   RootAllocator allocator)

Create the base operation

STPartition

public STPartition(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,
                   ArrowCallback receiver,
                   RootAllocator allocator)

Create the base operation

STPartition

public STPartition(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,
                   ArrowCallback receiver,
                   RootAllocator allocator,
                   java.lang.String name)

Create the base operation

Method Detail

insert

public boolean insert(int source,
                      Table t)

isComplete

public boolean isComplete()

Description copied from class: BaseOperation

Weather we have messages pending

Overrides:

isComplete in class BaseOperation

Returns:

true if there are messages pending

finish

public void finish(int src)

Description copied from class: BaseOperation

Indicate the end of the communication

Overrides:

finish in class BaseOperation

Parameters:

src - the source that is ending

progress

public boolean progress()

Description copied from class: BaseOperation

Progress the operation, if not called, messages will not be processed

Overrides:

progress in class BaseOperation

Returns:

true if further progress is needed

close

public void close()

Overrides:

close in class BaseOperation

reset

public void reset()

Description copied from class: BaseOperation

Clean the operation, this doesn't close it

Overrides:

reset in class BaseOperation

progressChannel

public boolean progressChannel()

Description copied from class: BaseOperation

Progress the channel and the operation

Overrides:

progressChannel in class BaseOperation

Returns:

true if further progress is required

sendBarrier

public boolean sendBarrier(int src,
                           byte[] barrierId)

Overrides:

sendBarrier in class BaseOperation

waitForCompletion

public void waitForCompletion()

Description copied from class: BaseOperation

Wait for the operation to complete

Overrides:

waitForCompletion in class BaseOperation