org.apache.beam.runners.flink

Class FlinkJobInvoker

java.lang.Object

org.apache.beam.runners.flink.FlinkJobInvoker

All Implemented Interfaces:

JobInvoker

public class FlinkJobInvoker
extends java.lang.Object
implements JobInvoker

Job Invoker for the FlinkRunner.

Method Summary

Modifier and Type	Method and Description
static FlinkJobInvoker	create(ListeningExecutorService executorService, FlinkJobServerDriver.ServerConfiguration serverConfig)
JobInvocation	invoke(org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline pipeline, org.apache.beam.vendor.grpc.v1_13_1.com.google.protobuf.Struct options, java.lang.String retrievalToken) Start running a job, abstracting its state as a JobInvocation instance.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

create

public static FlinkJobInvoker create(ListeningExecutorService executorService,
                                     FlinkJobServerDriver.ServerConfiguration serverConfig)

invoke

public JobInvocation invoke(org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline pipeline,
                            org.apache.beam.vendor.grpc.v1_13_1.com.google.protobuf.Struct options,
                            @Nullable
                            java.lang.String retrievalToken)
                     throws java.io.IOException

Description copied from interface: JobInvoker

Start running a job, abstracting its state as a JobInvocation instance.

Specified by:

invoke in interface JobInvoker

Throws:

java.io.IOException