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:

org.apache.flink.core.execution.PipelineExecutor

@Internal
@Deprecated
public class AbstractJobClusterExecutor<ClusterID,ClientFactory extends ClusterClientFactory<ClusterID>>
extends Object
implements org.apache.flink.core.execution.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<org.apache.flink.core.execution.JobClient>	execute(org.apache.flink.api.dag.Pipeline pipeline, org.apache.flink.configuration.Configuration configuration, ClassLoader userCodeClassloader)	Deprecated.

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<org.apache.flink.core.execution.JobClient> execute(@Nonnull
                                                                            org.apache.flink.api.dag.Pipeline pipeline,
                                                                            @Nonnull
                                                                            org.apache.flink.configuration.Configuration configuration,
                                                                            @Nonnull
                                                                            ClassLoader userCodeClassloader)
                                                                     throws Exception

Deprecated.

Specified by:

execute in interface org.apache.flink.core.execution.PipelineExecutor

Throws:

Exception