Package org.apache.flink.client.deployment.executors
-
Class Summary Class Description AbstractSessionClusterExecutor<ClusterID,ClientFactory extends ClusterClientFactory<ClusterID>> An abstractPipelineExecutorused to executepipelineson an existing (session) cluster.LocalExecutor AnPipelineExecutorfor executing aPipelinelocally.LocalExecutorFactory AnPipelineExecutorFactoryforlocal executors.PipelineExecutorUtils Utility class with method related to job execution.RemoteExecutor ThePipelineExecutorto be used when executing a job on an already running cluster.RemoteExecutorFactory AnPipelineExecutorFactoryforremote executors.