Modifier and Type | Class and Description |
---|---|
class |
JobMaster
JobMaster implementation.
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<JobMasterGateway> |
JobManagerRunner.getLeaderGatewayFuture() |
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 |
JobManagerConnection.getJobManagerGateway() |
Modifier and Type | Method and Description |
---|---|
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 |
---|
JobManagerConnection(JobID jobID,
ResourceID resourceID,
JobMasterGateway jobMasterGateway,
TaskManagerActions taskManagerActions,
CheckpointResponder checkpointResponder,
LibraryCacheManager libraryCacheManager,
ResultPartitionConsumableNotifier resultPartitionConsumableNotifier,
PartitionProducerStateChecker partitionStateChecker) |
Constructor and Description |
---|
RpcInputSplitProvider(JobMasterGateway jobMasterGateway,
JobVertexID jobVertexID,
ExecutionAttemptID executionAttemptID,
Time timeout) |
RpcPartitionStateChecker(JobMasterGateway jobMasterGateway) |
RpcResultPartitionConsumableNotifier(JobMasterGateway jobMasterGateway,
Executor executor,
Time timeout) |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.