public class FlinkPipelineRunner extends java.lang.Object implements PortablePipelineRunner
FlinkRunner
.Constructor and Description |
---|
FlinkPipelineRunner(FlinkPipelineOptions pipelineOptions,
java.lang.String confDir,
java.util.List<java.lang.String> filesToStage) |
Modifier and Type | Method and Description |
---|---|
static void |
main(java.lang.String[] args)
Main method to be called only as the entry point to an executable jar with structure as defined
in
PortablePipelineJarUtils . |
PortablePipelineResult |
run(org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline pipeline,
JobInfo jobInfo) |
public FlinkPipelineRunner(FlinkPipelineOptions pipelineOptions, @Nullable java.lang.String confDir, java.util.List<java.lang.String> filesToStage)
public PortablePipelineResult run(org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline pipeline, JobInfo jobInfo) throws java.lang.Exception
run
in interface PortablePipelineRunner
java.lang.Exception
public static void main(java.lang.String[] args) throws java.lang.Exception
PortablePipelineJarUtils
.java.lang.Exception