org.apache.flink.runtime.resourcemanager.registration

Class JobManagerRegistration

java.lang.Object

org.apache.flink.runtime.resourcemanager.registration.JobManagerRegistration

public class JobManagerRegistration
extends Object

Container for JobManager related registration information, such as the leader id or the job id.

Constructor Summary

Constructors

Constructor and Description
JobManagerRegistration(JobID jobID, ResourceID jobManagerResourceID, JobMasterGateway jobManagerGateway)

Method Summary

Modifier and Type	Method and Description
JobID	getJobID()
JobMasterGateway	getJobManagerGateway()
ResourceID	getJobManagerResourceID()
JobMasterId	getJobMasterId()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JobManagerRegistration

public JobManagerRegistration(JobID jobID,
                              ResourceID jobManagerResourceID,
                              JobMasterGateway jobManagerGateway)

Method Detail

getJobID

public JobID getJobID()

getJobManagerResourceID

public ResourceID getJobManagerResourceID()

getJobMasterId

public JobMasterId getJobMasterId()

getJobManagerGateway

public JobMasterGateway getJobManagerGateway()