public class Twister2LegacyRunner
extends <any>
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 and Description |
---|
Twister2LegacyRunner(Twister2PipelineOptions options) |
Modifier and Type | Method and Description |
---|---|
static Twister2LegacyRunner |
fromOptions(PipelineOptions options) |
PipelineResult |
run(Pipeline pipeline) |
public Twister2LegacyRunner(Twister2PipelineOptions options)
public static Twister2LegacyRunner fromOptions(PipelineOptions options)
public PipelineResult run(Pipeline pipeline)