org.apache.beam.runners.fnexecution.jobsubmission

Class JobInvoker

java.lang.Object

org.apache.beam.runners.fnexecution.jobsubmission.JobInvoker

Direct Known Subclasses:

FlinkJobInvoker, SparkJobInvoker

public abstract class JobInvoker
extends java.lang.Object

Factory to create JobInvocation instances.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	JobInvoker(java.lang.String name)

Method Summary

Modifier and Type	Method and Description
protected abstract 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.

Methods inherited from class java.lang.Object

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

Constructor Detail

JobInvoker

protected JobInvoker(java.lang.String name)

Method Detail

invokeWithExecutor

protected abstract 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)
                                             throws java.io.IOException

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

Throws:

java.io.IOException