Package org.apache.beam.runners.twister2
package org.apache.beam.runners.twister2
Internal implementation of the Beam runner for Twister2.
-
ClassDescriptionThis is a shell tset environment which is used on as a central driver model to fit what beam expects.The Twister2 worker that will execute the job logic once the job is submitted from the run method.Twister2BatchTranslationContext.Twister2PipelineExecutionEnvironment.Twister2PipelineOptions.Represents a Twister2 pipeline execution result.A
PipelineRunnerthat 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.AutoService registrar - will register Twister2Runner and Twister2Options as possible pipeline runner services.Pipeline options registrar.Pipeline runner registrar.Twister2StreamingTranslationContext.APipelineRunnerthat 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.Twister2TranslationContext.