edu.iu.dsc.tws.comms.batch

Class BPartition

java.lang.Object

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

edu.iu.dsc.tws.comms.batch.BPartition

public class BPartition
extends BaseOperation

Streaming Partition Operation

Field Summary

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

channel, op

Constructor Summary

Constructors

Constructor and Description
BPartition(Communicator comm, LogicalPlanBuilder logicalPlanBuilder, MessageType dataType, BulkReceiver rcvr, DestinationSelector destSelector, boolean shuffle)
BPartition(Communicator comm, LogicalPlan plan, java.util.Set<java.lang.Integer> sources, java.util.Set<java.lang.Integer> targets, MessageType dataType, BulkReceiver rcvr, DestinationSelector destSelector, boolean shuffle)
BPartition(Communicator comm, LogicalPlan plan, java.util.Set<java.lang.Integer> sources, java.util.Set<java.lang.Integer> targets, MessageType dataType, BulkReceiver rcvr, DestinationSelector destSelector, boolean shuffle, int edgeId, MessageSchema messageSchema) Construct a Batch partition operation
BPartition(Communicator comm, LogicalPlan plan, java.util.Set<java.lang.Integer> sources, java.util.Set<java.lang.Integer> targets, MessageType dataType, BulkReceiver rcvr, DestinationSelector destSelector, boolean shuffle, MessageSchema messageSchema)

Method Summary

Modifier and Type	Method and Description
boolean	partition(int source, java.lang.Object message, int flags) Send a message to be partitioned

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

close, finish, isComplete, progress, progressChannel, reset, sendBarrier, waitForCompletion

Methods inherited from class java.lang.Object

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

Constructor Detail

BPartition

public BPartition(Communicator comm,
                  LogicalPlan plan,
                  java.util.Set<java.lang.Integer> sources,
                  java.util.Set<java.lang.Integer> targets,
                  MessageType dataType,
                  BulkReceiver rcvr,
                  DestinationSelector destSelector,
                  boolean shuffle,
                  int edgeId,
                  MessageSchema messageSchema)

Construct a Batch partition operation

Parameters:

comm - the communicator

plan - task plan

sources - source tasks

targets - target tasks

rcvr - receiver

dataType - data type

destSelector - destination selector

BPartition

public BPartition(Communicator comm,
                  LogicalPlan plan,
                  java.util.Set<java.lang.Integer> sources,
                  java.util.Set<java.lang.Integer> targets,
                  MessageType dataType,
                  BulkReceiver rcvr,
                  DestinationSelector destSelector,
                  boolean shuffle,
                  MessageSchema messageSchema)

BPartition

public BPartition(Communicator comm,
                  LogicalPlan plan,
                  java.util.Set<java.lang.Integer> sources,
                  java.util.Set<java.lang.Integer> targets,
                  MessageType dataType,
                  BulkReceiver rcvr,
                  DestinationSelector destSelector,
                  boolean shuffle)

BPartition

public BPartition(Communicator comm,
                  LogicalPlanBuilder logicalPlanBuilder,
                  MessageType dataType,
                  BulkReceiver rcvr,
                  DestinationSelector destSelector,
                  boolean shuffle)

Method Detail

partition

public boolean partition(int source,
                         java.lang.Object message,
                         int flags)

Send a message to be partitioned

Parameters:

source - source

message - message

flags - message flag

Returns:

true if the message is accepted