Package org.apache.beam.runners.twister2
Class Twister2Runner
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.-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic Twister2Runner
fromOptions
(PipelineOptions options) Processes the givenPipeline
, potentially asynchronously, returning a runner-specific type of result.Methods inherited from class org.apache.beam.sdk.PipelineRunner
create, run, run
-
Constructor Details
-
Twister2Runner
-
-
Method Details
-
fromOptions
-
run
Description copied from class:PipelineRunner
Processes the givenPipeline
, potentially asynchronously, returning a runner-specific type of result.- Specified by:
run
in classPipelineRunner<PipelineResult>
-
runTest
-