Class Twister2Runner

java.lang.Object
org.apache.beam.sdk.PipelineRunner<PipelineResult>
org.apache.beam.runners.twister2.Twister2Runner

public class Twister2Runner extends PipelineRunner<PipelineResult>
A PipelineRunner that executes the operations in the pipeline by first translating them to a Twister2 Plan and then executing them either locally or on a Twister2 cluster, depending on the configuration.