public class FlinkJobInvoker extends JobInvoker
FlinkRunner
.Modifier | Constructor and Description |
---|---|
protected |
FlinkJobInvoker(FlinkJobServerDriver.FlinkServerConfiguration serverConfig) |
Modifier and Type | Method and Description |
---|---|
static FlinkJobInvoker |
create(FlinkJobServerDriver.FlinkServerConfiguration serverConfig) |
protected JobInvocation |
createJobInvocation(java.lang.String invocationId,
java.lang.String retrievalToken,
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.util.concurrent.ListeningExecutorService executorService,
org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline pipeline,
FlinkPipelineOptions flinkOptions,
PortablePipelineRunner pipelineRunner) |
protected JobInvocation |
invokeWithExecutor(org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline pipeline,
org.apache.beam.vendor.grpc.v1p21p0.com.google.protobuf.Struct options,
java.lang.String retrievalToken,
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.util.concurrent.ListeningExecutorService executorService)
Start running a job, abstracting its state as a
JobInvocation instance. |
protected FlinkJobInvoker(FlinkJobServerDriver.FlinkServerConfiguration serverConfig)
public static FlinkJobInvoker create(FlinkJobServerDriver.FlinkServerConfiguration serverConfig)
protected JobInvocation invokeWithExecutor(org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline pipeline, org.apache.beam.vendor.grpc.v1p21p0.com.google.protobuf.Struct options, @Nullable java.lang.String retrievalToken, org.apache.beam.vendor.guava.v26_0_jre.com.google.common.util.concurrent.ListeningExecutorService executorService)
JobInvoker
JobInvocation
instance.invokeWithExecutor
in class JobInvoker
protected JobInvocation createJobInvocation(java.lang.String invocationId, java.lang.String retrievalToken, org.apache.beam.vendor.guava.v26_0_jre.com.google.common.util.concurrent.ListeningExecutorService executorService, org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline pipeline, FlinkPipelineOptions flinkOptions, PortablePipelineRunner pipelineRunner)