Package org.apache.flink.client.deployment.executors
-
Class Summary Class Description AbstractJobClusterExecutor<ClusterID,ClientFactory extends ClusterClientFactory<ClusterID>> Deprecated. AbstractSessionClusterExecutor<ClusterID,ClientFactory extends ClusterClientFactory<ClusterID>> An abstractPipelineExecutor
used to executepipelines
on an existing (session) cluster.LocalExecutor AnPipelineExecutor
for executing aPipeline
locally.LocalExecutorFactory PipelineExecutorUtils Utility class with method related to job execution.RemoteExecutor ThePipelineExecutor
to be used when executing a job on an already running cluster.RemoteExecutorFactory