Package org.apache.beam.runners.twister2

Class BeamBatchWorker

java.lang.Object
org.apache.beam.runners.twister2.BeamBatchWorker
All Implemented Interfaces:
edu.iu.dsc.tws.api.resource.IWorker, edu.iu.dsc.tws.tset.worker.BatchTSetIWorker, Serializable
public class BeamBatchWorker extends Object implements Serializable, edu.iu.dsc.tws.tset.worker.BatchTSetIWorker
The Twister2 worker that will execute the job logic once the job is submitted from the run method.
See Also:

  • Constructor Summary

    Constructors
    Constructor
    Description
    BeamBatchWorker()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    eval(edu.iu.dsc.tws.tset.env.BatchTSetEnvironment env, edu.iu.dsc.tws.tset.sets.batch.SinkTSet<?> tSet)
     
    void
    execute(edu.iu.dsc.tws.tset.env.BatchTSetEnvironment env)
     
    void
    executePipeline(edu.iu.dsc.tws.tset.env.BatchTSetEnvironment env)
     

    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.tset.worker.BatchTSetIWorker

    execute, retrieveWorkerEnvironment

  • Constructor Details

    • BeamBatchWorker

      public BeamBatchWorker()

  • Method Details

    • execute

      public void execute(edu.iu.dsc.tws.tset.env.BatchTSetEnvironment env)
      Specified by:
      execute in interface edu.iu.dsc.tws.tset.worker.BatchTSetIWorker

    • executePipeline

      public void executePipeline(edu.iu.dsc.tws.tset.env.BatchTSetEnvironment env)

    • eval

      public void eval(edu.iu.dsc.tws.tset.env.BatchTSetEnvironment env, edu.iu.dsc.tws.tset.sets.batch.SinkTSet<?> tSet)