org.apache.beam.runners.twister2

Class BeamBatchTSetEnvironment

java.lang.Object

edu.iu.dsc.tws.tset.env.TSetEnvironment

edu.iu.dsc.tws.tset.env.BatchTSetEnvironment

org.apache.beam.runners.twister2.BeamBatchTSetEnvironment

public class BeamBatchTSetEnvironment
extends edu.iu.dsc.tws.tset.env.BatchTSetEnvironment

This is a shell tset environment which is used on as a central driver model to fit what beam expects. This will be used to develop the TSet graph corresponding to the Beam Pipeline which will later be injected into the correct TSetEnvironment one submitted.

Constructor Summary

Constructors

Constructor and Description
BeamBatchTSetEnvironment()

Method Summary

Modifier and Type	Method and Description
edu.iu.dsc.tws.api.compute.graph.OperationMode	getOperationMode()

Methods inherited from class edu.iu.dsc.tws.tset.env.BatchTSetEnvironment

createHadoopSource, createHadoopSource, createKeyedHadoopSource, createKeyedSource, createKeyedSource, createSource, createSource, eval, evalAndUpdate, finishEval, getData, run, runAndUpdate, runOne

Methods inherited from class edu.iu.dsc.tws.tset.env.TSetEnvironment

addInput, close, executeBuildContext, getConfig, getDefaultParallelism, getGraph, getInputs, getNoOfWorkers, getTaskExecutor, getTSetGraph, getWorkerID, initBatch, initStreaming, isCheckpointingEnabled, parallelize, parallelize, parallelize, parallelize, setDefaultParallelism, settBaseGraph

Methods inherited from class java.lang.Object

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

Constructor Detail

BeamBatchTSetEnvironment

public BeamBatchTSetEnvironment()

Method Detail

getOperationMode

public edu.iu.dsc.tws.api.compute.graph.OperationMode getOperationMode()

Overrides:

getOperationMode in class edu.iu.dsc.tws.tset.env.BatchTSetEnvironment