Modifier and Type | Method and Description |
---|---|
CompletableFuture<JobMasterGateway> |
DispatcherJob.getJobMasterGateway()
Returns the
JobMasterGateway from the JobManagerRunner. |
Modifier and Type | Class and Description |
---|---|
class |
JobMaster
JobMaster implementation.
|
Modifier and Type | Method and Description |
---|---|
JobMasterGateway |
JobMaster.getGateway() |
JobMasterGateway |
JobMasterService.getGateway()
Get the
JobMasterGateway belonging to this service. |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<JobMasterGateway> |
JobManagerRunner.getJobMasterGateway()
Get the
JobMasterGateway of the JobMaster . |
CompletableFuture<JobMasterGateway> |
JobManagerRunnerImpl.getJobMasterGateway() |
Modifier and Type | Method and Description |
---|---|
JobMasterGateway |
JobManagerRegistration.getJobManagerGateway() |
Constructor and Description |
---|
JobManagerRegistration(JobID jobID,
ResourceID jobManagerResourceID,
JobMasterGateway jobManagerGateway) |
Modifier and Type | Method and Description |
---|---|
JobMasterGateway |
JobTable.Connection.getJobManagerGateway() |
Modifier and Type | Method and Description |
---|---|
JobTable.Connection |
JobTable.Job.connect(ResourceID resourceId,
JobMasterGateway jobMasterGateway,
TaskManagerActions taskManagerActions,
CheckpointResponder checkpointResponder,
GlobalAggregateManager aggregateManager,
ResultPartitionConsumableNotifier resultPartitionConsumableNotifier,
PartitionProducerStateChecker partitionStateChecker)
Connects the job to a JobManager and associates the provided services with this
connection.
|
void |
JobLeaderListener.jobManagerGainedLeadership(JobID jobId,
JobMasterGateway jobManagerGateway,
JMTMRegistrationSuccess registrationMessage)
Callback if a job manager has gained leadership for the job identified by the job id and a
connection could be established to this job manager.
|
Constructor and Description |
---|
RpcGlobalAggregateManager(JobMasterGateway jobMasterGateway) |
RpcInputSplitProvider(JobMasterGateway jobMasterGateway,
JobVertexID jobVertexID,
ExecutionAttemptID executionAttemptID,
Time timeout) |
RpcPartitionStateChecker(JobMasterGateway jobMasterGateway) |
RpcResultPartitionConsumableNotifier(JobMasterGateway jobMasterGateway,
Executor executor,
Time timeout) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.