edu.iu.dsc.tws.executor.core

Class ParallelOperationFactory

java.lang.Object

edu.iu.dsc.tws.executor.core.ParallelOperationFactory

public class ParallelOperationFactory
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
ParallelOperationFactory(Config cfg, Communicator network, LogicalPlan plan)

Method Summary

Modifier and Type	Method and Description
IParallelOperation	build(Edge leftEdge, Edge rightEdge, java.util.Set<java.lang.Integer> sources1, java.util.Set<java.lang.Integer> sources2, java.util.Set<java.lang.Integer> dests, OperationMode operationMode, java.util.Map<java.lang.Integer,java.lang.Integer> srcGlobalToIndx, java.util.Map<java.lang.Integer,java.lang.Integer> tgtsGlobalToIndx)
IParallelOperation	build(Edge edge, java.util.Set<java.lang.Integer> sources, java.util.Set<java.lang.Integer> dests, OperationMode operationMode, java.util.Map<java.lang.Integer,java.lang.Integer> srcGlobalToIndx, java.util.Map<java.lang.Integer,java.lang.Integer> tgtsGlobalToIndx) Building the parallel operation based on the batch or streaming tasks.

Methods inherited from class java.lang.Object

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

Constructor Detail

ParallelOperationFactory

public ParallelOperationFactory(Config cfg,
                                Communicator network,
                                LogicalPlan plan)

Method Detail

build

public IParallelOperation build(Edge leftEdge,
                                Edge rightEdge,
                                java.util.Set<java.lang.Integer> sources1,
                                java.util.Set<java.lang.Integer> sources2,
                                java.util.Set<java.lang.Integer> dests,
                                OperationMode operationMode,
                                java.util.Map<java.lang.Integer,java.lang.Integer> srcGlobalToIndx,
                                java.util.Map<java.lang.Integer,java.lang.Integer> tgtsGlobalToIndx)

build

public IParallelOperation build(Edge edge,
                                java.util.Set<java.lang.Integer> sources,
                                java.util.Set<java.lang.Integer> dests,
                                OperationMode operationMode,
                                java.util.Map<java.lang.Integer,java.lang.Integer> srcGlobalToIndx,
                                java.util.Map<java.lang.Integer,java.lang.Integer> tgtsGlobalToIndx)

Building the parallel operation based on the batch or streaming tasks. And also the sub cateogories depends on the communication used for each edge in the task graph.