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

Interface EmbeddedJobClientCreator

@Internal
public interface EmbeddedJobClientCreator

An interface to be implemented by JobClient suppliers.

Method Summary

Modifier and Type	Method and Description
JobClient	getJobClient(JobID jobId, ClassLoader userCodeClassloader) Creates a JobClient that is adequate for the context in which the job is executed.

Method Detail

getJobClient

JobClient getJobClient(JobID jobId,
                       ClassLoader userCodeClassloader)

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

Parameters:

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

userCodeClassloader - the class loader to deserialize user code.

Returns:

the job client.