edu.iu.dsc.tws.executor.comms.batch

Class JoinBatchOperation

java.lang.Object

edu.iu.dsc.tws.executor.comms.AbstractParallelOperation

edu.iu.dsc.tws.executor.comms.batch.JoinBatchOperation

All Implemented Interfaces:

IParallelOperation

public class JoinBatchOperation
extends AbstractParallelOperation

Field Summary

Fields

Modifier and Type	Field and Description
protected BJoin	op

Fields inherited from class edu.iu.dsc.tws.executor.comms.AbstractParallelOperation

channel, config, inEdge, logicalPlan, outMessages, syncs

Constructor Summary

Constructors

Constructor and Description

JoinBatchOperation(Config config, Communicator network, LogicalPlan tPlan, java.util.Set<java.lang.Integer> sources1, java.util.Set<java.lang.Integer> sources2, java.util.Set<java.lang.Integer> dests, Edge leftEdge, Edge rightEdge, java.util.Map<java.lang.Integer,java.lang.Integer> srcGlobalToIndex, java.util.Map<java.lang.Integer,java.lang.Integer> tgtsGlobalToIndex) Creates an instance of JoinBatchOperation

Method Summary

Modifier and Type	Method and Description
void	close() Close the parallel operation
void	finish(int source) Indicate the end of the operation
BaseOperation	getOp()
void	reset() Refresh the operation to start from beginning
boolean	send(int source, IMessage message, int flags) Send a message over the operation

Methods inherited from class edu.iu.dsc.tws.executor.comms.AbstractParallelOperation

isComplete, progress, register, registerSync

Methods inherited from class java.lang.Object

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

Methods inherited from interface edu.iu.dsc.tws.api.compute.executor.IParallelOperation

sendBarrier

Field Detail

op

protected BJoin op

Constructor Detail

JoinBatchOperation

public JoinBatchOperation(Config config,
                          Communicator network,
                          LogicalPlan tPlan,
                          java.util.Set<java.lang.Integer> sources1,
                          java.util.Set<java.lang.Integer> sources2,
                          java.util.Set<java.lang.Integer> dests,
                          Edge leftEdge,
                          Edge rightEdge,
                          java.util.Map<java.lang.Integer,java.lang.Integer> srcGlobalToIndex,
                          java.util.Map<java.lang.Integer,java.lang.Integer> tgtsGlobalToIndex)

Creates an instance of JoinBatchOperation

Method Detail

send

public boolean send(int source,
                    IMessage message,
                    int flags)

Description copied from interface: IParallelOperation

Send a message over the operation

Parameters:

source - source

message - the message

finish

public void finish(int source)

Description copied from interface: IParallelOperation

Indicate the end of the operation

Specified by:

finish in interface IParallelOperation

Overrides:

finish in class AbstractParallelOperation

Parameters:

source - the source

close

public void close()

Description copied from interface: IParallelOperation

Close the parallel operation

Specified by:

close in interface IParallelOperation

Overrides:

close in class AbstractParallelOperation

reset

public void reset()

Description copied from interface: IParallelOperation

Refresh the operation to start from beginning

Specified by:

reset in interface IParallelOperation

Overrides:

reset in class AbstractParallelOperation

getOp

public BaseOperation getOp()