Package org.apache.beam.runners.twister2

Class Twister2PipelineExecutionEnvironment

java.lang.Object

org.apache.beam.runners.twister2.Twister2PipelineExecutionEnvironment

public class Twister2PipelineExecutionEnvironment
extends Object

Twister2PipelineExecutionEnvironment.

Constructor Summary

Constructors

Constructor	Description
Twister2PipelineExecutionEnvironment(Twister2PipelineOptions options)

Method Summary

Modifier and Type	Method	Description
Set<edu.iu.dsc.tws.api.tset.sets.TSet>	getLeaves()
Map<String,edu.iu.dsc.tws.api.tset.sets.batch.BatchTSet<?>>	getSideInputs()
protected edu.iu.dsc.tws.tset.TBaseGraph	getTSetGraph()
void	translate(Pipeline pipeline)	translate the pipline into Twister2 TSet graph.

Methods inherited from class java.lang.Object

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

Constructor Details

Twister2PipelineExecutionEnvironment

public Twister2PipelineExecutionEnvironment(Twister2PipelineOptions options)

Method Details

translate

public void translate(Pipeline pipeline)

translate the pipline into Twister2 TSet graph.

getSideInputs

public Map<String,edu.iu.dsc.tws.api.tset.sets.batch.BatchTSet<?>> getSideInputs()

getLeaves

public Set<edu.iu.dsc.tws.api.tset.sets.TSet> getLeaves()

getTSetGraph

protected edu.iu.dsc.tws.tset.TBaseGraph getTSetGraph()