org.apache.beam.runners.twister2

Class Twister2PipelineExecutionEnvironment

java.lang.Object

org.apache.beam.runners.twister2.Twister2PipelineExecutionEnvironment

public class Twister2PipelineExecutionEnvironment
extends java.lang.Object

Twister2PipelineExecutionEnvironment.

Constructor Summary

Constructors

Constructor and Description
Twister2PipelineExecutionEnvironment(Twister2PipelineOptions options)

Method Summary

Modifier and Type	Method and Description
java.util.Set<edu.iu.dsc.tws.api.tset.sets.TSet>	getLeaves()
java.util.Map<java.lang.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 Detail

Twister2PipelineExecutionEnvironment

public Twister2PipelineExecutionEnvironment(Twister2PipelineOptions options)

Method Detail

translate

public void translate(Pipeline pipeline)

translate the pipline into Twister2 TSet graph.

getSideInputs

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

getLeaves

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

getTSetGraph

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