edu.iu.dsc.tws.comms.stream

Class SKeyedPartition

java.lang.Object

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

edu.iu.dsc.tws.comms.stream.SKeyedPartition

public class SKeyedPartition
extends BaseOperation

Streaming Keyed Partition Operation

Field Summary

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

channel, op

Constructor Summary

Constructors

Constructor and Description
SKeyedPartition(Communicator comm, LogicalPlanBuilder logicalPlanBuilder, MessageType keyType, MessageType dataType, SingularReceiver rcvr, DestinationSelector destSelector)
SKeyedPartition(Communicator comm, LogicalPlan plan, java.util.Set<java.lang.Integer> sources, java.util.Set<java.lang.Integer> targets, MessageType keyType, MessageType dataType, SingularReceiver rcvr, DestinationSelector destSelector)
SKeyedPartition(Communicator comm, LogicalPlan plan, java.util.Set<java.lang.Integer> sources, java.util.Set<java.lang.Integer> targets, MessageType keyType, MessageType dataType, SingularReceiver rcvr, DestinationSelector destSelector, int edgeId, MessageSchema messageSchema) Construct a Streaming Key based partition operation
SKeyedPartition(Communicator comm, LogicalPlan plan, java.util.Set<java.lang.Integer> sources, java.util.Set<java.lang.Integer> targets, MessageType keyType, MessageType dataType, SingularReceiver rcvr, DestinationSelector destSelector, MessageSchema messageSchema)

Method Summary

Modifier and Type	Method and Description
boolean	partition(int src, java.lang.Object key, java.lang.Object message, int flags) Send a message to be partitioned based on the key
boolean	partition(int src, Tuple data, int flags) Send a message to be partitioned based on the key

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

SKeyedPartition

public SKeyedPartition(Communicator comm,
                       LogicalPlan plan,
                       java.util.Set<java.lang.Integer> sources,
                       java.util.Set<java.lang.Integer> targets,
                       MessageType keyType,
                       MessageType dataType,
                       SingularReceiver rcvr,
                       DestinationSelector destSelector,
                       int edgeId,
                       MessageSchema messageSchema)

Construct a Streaming Key based partition operation

Parameters:

comm - the communicator

plan - task plan

sources - source tasks

targets - target tasks

rcvr - receiver

dataType - data type

SKeyedPartition

public SKeyedPartition(Communicator comm,
                       LogicalPlan plan,
                       java.util.Set<java.lang.Integer> sources,
                       java.util.Set<java.lang.Integer> targets,
                       MessageType keyType,
                       MessageType dataType,
                       SingularReceiver rcvr,
                       DestinationSelector destSelector)

SKeyedPartition

public SKeyedPartition(Communicator comm,
                       LogicalPlanBuilder logicalPlanBuilder,
                       MessageType keyType,
                       MessageType dataType,
                       SingularReceiver rcvr,
                       DestinationSelector destSelector)

SKeyedPartition

public SKeyedPartition(Communicator comm,
                       LogicalPlan plan,
                       java.util.Set<java.lang.Integer> sources,
                       java.util.Set<java.lang.Integer> targets,
                       MessageType keyType,
                       MessageType dataType,
                       SingularReceiver rcvr,
                       DestinationSelector destSelector,
                       MessageSchema messageSchema)

Method Detail

partition

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

Send a message to be partitioned based on the key

Parameters:

src - source

key - key

message - message

flags - message flag

Returns:

true if the message is accepted

partition

public boolean partition(int src,
                         Tuple data,
                         int flags)

Send a message to be partitioned based on the key

Parameters:

src - source

data - tuple

flags - message flag

Returns:

true if the message is accepted