首页 笔记 图片 查字 
所属分类:Flink
浏览:25
内容:

要点:
JobClient 接口
public interface JobClient

1、EmbeddedJobClient (org.apache.flink.client.deployment.application)
public class EmbeddedJobClient implements JobClient, CoordinationRequestGateway
    private final JobID jobId;
    private final DispatcherGateway dispatcherGateway;
    private final ScheduledExecutor retryExecutor;
    private final Time timeout;
    private final ClassLoader classLoader;

2、MiniClusterJobClient (org.apache.flink.runtime.minicluster)
public final class MiniClusterJobClient implements JobClient, CoordinationRequestGateway
    private final JobID jobID;
    private final MiniCluster miniCluster;
    private final ClassLoader classLoader;
    private final CompletableFuture<JobResult> jobResultFuture;

3、WebSubmissionJobClient (org.apache.flink.client.deployment.application)
public class WebSubmissionJobClient implements JobClient
    private final JobID jobId;

4、ClusterClientJobClientAdapter (org.apache.flink.client.deployment)
public class ClusterClientJobClientAdapter<ClusterID> implements JobClient, CoordinationRequestGateway
    private final ClusterClientProvider<ClusterID> clusterClientProvider;
    private final JobID jobID;
    private final ClassLoader classLoader;