Package 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
    Description
    BeamBatchTSetEnvironment()
     

  • Method Summary

    Modifier and Type
    Method
    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 Details

    • BeamBatchTSetEnvironment

      public BeamBatchTSetEnvironment()

  • Method Details

    • getOperationMode

      public edu.iu.dsc.tws.api.compute.graph.OperationMode getOperationMode()
      Overrides:
      getOperationMode in class edu.iu.dsc.tws.tset.env.BatchTSetEnvironment