edu.iu.dsc.tws.comms.batch

Class BKeyedPartition

java.lang.Object

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

edu.iu.dsc.tws.comms.batch.BKeyedPartition

public class BKeyedPartition
extends BaseOperation

Field Summary

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

channel, op

Constructor Summary

Constructors

Constructor and Description
BKeyedPartition(Communicator comm, LogicalPlanBuilder logicalPlanBuilder, MessageType keyType, MessageType dataType, BulkReceiver rcvr, DestinationSelector destSelector)
BKeyedPartition(Communicator comm, LogicalPlan plan, java.util.Set<java.lang.Integer> sources, java.util.Set<java.lang.Integer> destinations, MessageType keyType, MessageType dataType, BulkReceiver rcvr, DestinationSelector destSelector)
BKeyedPartition(Communicator comm, LogicalPlan plan, java.util.Set<java.lang.Integer> sources, java.util.Set<java.lang.Integer> destinations, MessageType keyType, MessageType dataType, BulkReceiver rcvr, DestinationSelector destSelector, int edgeId, MessageSchema messageSchema)
BKeyedPartition(Communicator comm, LogicalPlan plan, java.util.Set<java.lang.Integer> sources, java.util.Set<java.lang.Integer> destinations, MessageType keyType, MessageType dataType, BulkReceiver rcvr, DestinationSelector destSelector, MessageSchema messageSchema)

Method Summary

Modifier and Type	Method and Description
boolean	partition(int source, java.lang.Object key, java.lang.Object message, int flags)
boolean	partition(int src, Tuple data, int flags)

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

BKeyedPartition

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

BKeyedPartition

public BKeyedPartition(Communicator comm,
                       LogicalPlan plan,
                       java.util.Set<java.lang.Integer> sources,
                       java.util.Set<java.lang.Integer> destinations,
                       MessageType keyType,
                       MessageType dataType,
                       BulkReceiver rcvr,
                       DestinationSelector destSelector)

BKeyedPartition

public BKeyedPartition(Communicator comm,
                       LogicalPlanBuilder logicalPlanBuilder,
                       MessageType keyType,
                       MessageType dataType,
                       BulkReceiver rcvr,
                       DestinationSelector destSelector)

BKeyedPartition

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

Method Detail

partition

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

partition

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