org.apache.flink.client.deployment.application.executors

接口 EmbeddedJobClientCreator

@Internal
public interface EmbeddedJobClientCreator

An interface to be implemented by JobClient suppliers.

方法概要

限定符和类型	方法和说明
org.apache.flink.core.execution.JobClient	getJobClient(org.apache.flink.api.common.JobID jobId) Creates a JobClient that is adequate for the context in which the job is executed.

方法详细资料

getJobClient

org.apache.flink.core.execution.JobClient getJobClient(org.apache.flink.api.common.JobID jobId)

Creates a JobClient that is adequate for the context in which the job is executed.

参数:

jobId - the job id of the job associated with the returned client.

返回:

the job client.