edu.iu.dsc.tws.comms.batch

Class BKeyedGather

java.lang.Object

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

edu.iu.dsc.tws.comms.batch.BKeyedGather

public class BKeyedGather
extends BaseOperation

Field Summary

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

channel, op

Constructor Summary

Constructors

Constructor and Description
BKeyedGather(Communicator comm, LogicalPlanBuilder logicalPlanBuilder, MessageType kType, MessageType dType, BulkReceiver rcvr, DestinationSelector destSelector)
BKeyedGather(Communicator comm, LogicalPlanBuilder logicalPlanBuilder, MessageType kType, MessageType dType, BulkReceiver rcvr, DestinationSelector destSelector, boolean useDisk, java.util.Comparator<java.lang.Object> comparator, boolean groupByKey)
BKeyedGather(Communicator comm, LogicalPlanBuilder logicalPlanBuilder, MessageType kType, MessageType dType, BulkReceiver rcvr, DestinationSelector destSelector, boolean useDisk, java.util.Comparator<java.lang.Object> comparator, boolean groupByKey, MessageSchema schema)
BKeyedGather(Communicator comm, LogicalPlan plan, java.util.Set<java.lang.Integer> sources, java.util.Set<java.lang.Integer> destinations, MessageType kType, MessageType dType, BulkReceiver rcvr, DestinationSelector destSelector) Creates an instance of BKeyedGather without shuffling
BKeyedGather(Communicator comm, LogicalPlan plan, java.util.Set<java.lang.Integer> sources, java.util.Set<java.lang.Integer> destinations, MessageType kType, MessageType dType, BulkReceiver rcvr, DestinationSelector destSelector, boolean useDisk, java.util.Comparator<java.lang.Object> comparator, boolean groupByKey)
BKeyedGather(Communicator comm, LogicalPlan plan, java.util.Set<java.lang.Integer> sources, java.util.Set<java.lang.Integer> destinations, MessageType kType, MessageType dType, BulkReceiver rcvr, DestinationSelector destSelector, boolean useDisk, java.util.Comparator<java.lang.Object> comparator, boolean groupByKey, int edgeId, MessageSchema messageSchema) Creates an instance of BKeyedGather with key comparator
BKeyedGather(Communicator comm, LogicalPlan plan, java.util.Set<java.lang.Integer> sources, java.util.Set<java.lang.Integer> destinations, MessageType kType, MessageType dType, BulkReceiver rcvr, DestinationSelector destSelector, boolean useDisk, java.util.Comparator<java.lang.Object> comparator, boolean groupByKey, MessageSchema messageSchema)
BKeyedGather(Communicator comm, LogicalPlan plan, java.util.Set<java.lang.Integer> sources, java.util.Set<java.lang.Integer> destinations, MessageType kType, MessageType dType, BulkReceiver rcvr, DestinationSelector destSelector, MessageSchema messageSchema)

Method Summary

Modifier and Type	Method and Description
boolean	gather(int source, java.lang.Object key, java.lang.Object data, int flags)
boolean	gather(int src, Tuple data, int flags)
boolean	progressChannel() Progress the channel and the operation

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

BKeyedGather

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

Creates an instance of BKeyedGather without shuffling

BKeyedGather

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

BKeyedGather

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

BKeyedGather

public BKeyedGather(Communicator comm,
                    LogicalPlan plan,
                    java.util.Set<java.lang.Integer> sources,
                    java.util.Set<java.lang.Integer> destinations,
                    MessageType kType,
                    MessageType dType,
                    BulkReceiver rcvr,
                    DestinationSelector destSelector,
                    boolean useDisk,
                    java.util.Comparator<java.lang.Object> comparator,
                    boolean groupByKey,
                    MessageSchema messageSchema)

BKeyedGather

public BKeyedGather(Communicator comm,
                    LogicalPlan plan,
                    java.util.Set<java.lang.Integer> sources,
                    java.util.Set<java.lang.Integer> destinations,
                    MessageType kType,
                    MessageType dType,
                    BulkReceiver rcvr,
                    DestinationSelector destSelector,
                    boolean useDisk,
                    java.util.Comparator<java.lang.Object> comparator,
                    boolean groupByKey)

BKeyedGather

public BKeyedGather(Communicator comm,
                    LogicalPlanBuilder logicalPlanBuilder,
                    MessageType kType,
                    MessageType dType,
                    BulkReceiver rcvr,
                    DestinationSelector destSelector,
                    boolean useDisk,
                    java.util.Comparator<java.lang.Object> comparator,
                    boolean groupByKey)

BKeyedGather

public BKeyedGather(Communicator comm,
                    LogicalPlanBuilder logicalPlanBuilder,
                    MessageType kType,
                    MessageType dType,
                    BulkReceiver rcvr,
                    DestinationSelector destSelector,
                    boolean useDisk,
                    java.util.Comparator<java.lang.Object> comparator,
                    boolean groupByKey,
                    MessageSchema schema)

BKeyedGather

public BKeyedGather(Communicator comm,
                    LogicalPlan plan,
                    java.util.Set<java.lang.Integer> sources,
                    java.util.Set<java.lang.Integer> destinations,
                    MessageType kType,
                    MessageType dType,
                    BulkReceiver rcvr,
                    DestinationSelector destSelector,
                    boolean useDisk,
                    java.util.Comparator<java.lang.Object> comparator,
                    boolean groupByKey,
                    int edgeId,
                    MessageSchema messageSchema)

Creates an instance of BKeyedGather with key comparator

Parameters:

comparator - Comparator to use for sorting keys

Method Detail

gather

public boolean gather(int source,
                      java.lang.Object key,
                      java.lang.Object data,
                      int flags)

gather

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

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