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, java.io.Serializable

public class BeamBatchWorker
extends java.lang.Object
implements java.io.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:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
BeamBatchWorker()

Method Summary

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

BeamBatchWorker

public BeamBatchWorker()

Method Detail

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)