org.apache.beam.runners.twister2

Class BeamBatchTSetEnvironment

java.lang.Object

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

edu.iu.dsc.tws.tset.env.BatchEnvironment

org.apache.beam.runners.twister2.BeamBatchTSetEnvironment

public class BeamBatchTSetEnvironment
extends BatchEnvironment

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
OperationMode	getOperationMode() Returns the OperationMode

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

createArrowSource, createArrowSource, createCSVSource, createHadoopSource, createHadoopSource, createKeyedHadoopSource, createKeyedSource, createKeyedSource, createRowSource, createSource, createSource, createTextSource, 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, getWorkerEnv, getWorkerID, initBatch, initCheckpointing, 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 OperationMode getOperationMode()

Description copied from class: TSetEnvironment

Returns the OperationMode

Overrides:

getOperationMode in class BatchEnvironment

Returns:

operation mode