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

Interface EmbeddedJobClientCreator

  • @Internal
public interface EmbeddedJobClientCreator
    An interface to be implemented by JobClient suppliers.

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      org.apache.flink.core.execution.JobClient getJobClient​(org.apache.flink.api.common.JobID jobId, ClassLoader userCodeClassloader)
      Creates a JobClient that is adequate for the context in which the job is executed.

    • Method Detail

      • getJobClient

        org.apache.flink.core.execution.JobClient getJobClient​(org.apache.flink.api.common.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.