org.apache.beam.runners.twister2

Class Twister2PiplineExecutionEnvironment

java.lang.Object

org.apache.beam.runners.twister2.Twister2PiplineExecutionEnvironment

public class Twister2PiplineExecutionEnvironment
extends java.lang.Object

Twister2PiplineExecutionEnvironment.

Constructor Summary

Constructors

Constructor and Description
Twister2PiplineExecutionEnvironment(Twister2PipelineOptions options)

Method Summary

Modifier and Type	Method and Description
void	execute() Execute all the task graphs.
java.util.Set<TSet>	getLeaves()
java.util.Map<java.lang.String,BatchTSet<?>>	getSideInputs()
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

Twister2PiplineExecutionEnvironment

public Twister2PiplineExecutionEnvironment(Twister2PipelineOptions options)

Method Detail

translate

public void translate(Pipeline pipeline)

translate the pipline into Twister2 TSet graph.

execute

public void execute()

Execute all the task graphs.

getSideInputs

public java.util.Map<java.lang.String,BatchTSet<?>> getSideInputs()

getLeaves

public java.util.Set<TSet> getLeaves()