Package org.apache.flink.client.deployment.executors

Class AbstractJobClusterExecutor<ClusterID,ClientFactory extends ClusterClientFactory<ClusterID>>

java.lang.Object

org.apache.flink.client.deployment.executors.AbstractJobClusterExecutor<ClusterID,ClientFactory>

Type Parameters:

ClusterID - the type of the id of the cluster.

ClientFactory - the type of the ClusterClientFactory used to create/retrieve a client to the target cluster.

All Implemented Interfaces:

PipelineExecutor

Direct Known Subclasses:

YarnJobClusterExecutor

@Internal
@Deprecated
public class AbstractJobClusterExecutor<ClusterID,ClientFactory extends ClusterClientFactory<ClusterID>>
extends Object
implements PipelineExecutor

Deprecated.

An abstract PipelineExecutor used to execute pipelines on dedicated (per-job) clusters.

Constructor Summary

Constructors

Constructor	Description
AbstractJobClusterExecutor(ClientFactory clusterClientFactory)	Deprecated.

Method Summary

Modifier and Type	Method	Description
CompletableFuture<JobClient>	execute(Pipeline pipeline, Configuration configuration, ClassLoader userCodeClassloader)	Deprecated. Executes a Pipeline based on the provided configuration and returns a JobClient which allows to interact with the job being executed, e.g. cancel it or take a savepoint.

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractJobClusterExecutor

public AbstractJobClusterExecutor(@Nonnull
                                  ClientFactory clusterClientFactory)

Deprecated.

Method Detail

execute

public CompletableFuture<JobClient> execute(@Nonnull
                                            Pipeline pipeline,
                                            @Nonnull
                                            Configuration configuration,
                                            @Nonnull
                                            ClassLoader userCodeClassloader)
                                     throws Exception

Deprecated.

Description copied from interface: PipelineExecutor

Executes a Pipeline based on the provided configuration and returns a JobClient which allows to interact with the job being executed, e.g. cancel it or take a savepoint.

ATTENTION: The caller is responsible for managing the lifecycle of the returned JobClient. This means that e.g. close() should be called explicitly at the call-site.

Specified by:

execute in interface PipelineExecutor

Parameters:

pipeline - the Pipeline to execute

configuration - the Configuration with the required execution parameters

userCodeClassloader - the ClassLoader to deserialize usercode

Returns:

a CompletableFuture with the JobClient corresponding to the pipeline.

Throws:

Exception