edu.iu.dsc.tws.comms.stream

Class SKeyedGather

java.lang.Object

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

edu.iu.dsc.tws.comms.stream.SKeyedGather

public class SKeyedGather
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
SKeyedGather(Communicator comm, LogicalPlanBuilder logicalPlanBuilder, MessageType kType, MessageType dType, BulkReceiver rcvr, DestinationSelector destSelector)
SKeyedGather(Communicator comm, LogicalPlan plan, java.util.Set<java.lang.Integer> sources, java.util.Set<java.lang.Integer> targets, MessageType kType, MessageType dType, BulkReceiver rcvr, DestinationSelector destSelector)
SKeyedGather(Communicator comm, LogicalPlan plan, java.util.Set<java.lang.Integer> sources, java.util.Set<java.lang.Integer> targets, MessageType kType, MessageType dType, BulkReceiver rcvr, DestinationSelector destSelector, int edgeId, MessageSchema messageSchema) Construct a Streaming Key based partition operation
SKeyedGather(Communicator comm, LogicalPlan plan, java.util.Set<java.lang.Integer> sources, java.util.Set<java.lang.Integer> targets, MessageType kType, MessageType dType, BulkReceiver rcvr, DestinationSelector destSelector, MessageSchema messageSchema)

Method Summary

Modifier and Type	Method and Description
boolean	gather(int src, java.lang.Object key, java.lang.Object message, int flags) Send a message to be reduced
boolean	gather(int src, Tuple data, int flags) Send a message to be reduced

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

SKeyedGather

public SKeyedGather(Communicator comm,
                    LogicalPlan plan,
                    java.util.Set<java.lang.Integer> sources,
                    java.util.Set<java.lang.Integer> targets,
                    MessageType kType,
                    MessageType dType,
                    BulkReceiver 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

dType - data type

kType - key type

rcvr - receiver

destSelector - destination selector

SKeyedGather

public SKeyedGather(Communicator comm,
                    LogicalPlan plan,
                    java.util.Set<java.lang.Integer> sources,
                    java.util.Set<java.lang.Integer> targets,
                    MessageType kType,
                    MessageType dType,
                    BulkReceiver rcvr,
                    DestinationSelector destSelector)

SKeyedGather

public SKeyedGather(Communicator comm,
                    LogicalPlanBuilder logicalPlanBuilder,
                    MessageType kType,
                    MessageType dType,
                    BulkReceiver rcvr,
                    DestinationSelector destSelector)

SKeyedGather

public SKeyedGather(Communicator comm,
                    LogicalPlan plan,
                    java.util.Set<java.lang.Integer> sources,
                    java.util.Set<java.lang.Integer> targets,
                    MessageType kType,
                    MessageType dType,
                    BulkReceiver rcvr,
                    DestinationSelector destSelector,
                    MessageSchema messageSchema)

Method Detail

gather

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

Send a message to be reduced

Parameters:

src - source

key - key

message - message

flags - message flag

Returns:

true if the message is accepted

gather

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

Send a message to be reduced

Parameters:

src - source

data - data tuple

flags - message flag

Returns:

true if the message is accepted