Modifier and Type | Method and Description |
---|---|
static JobMasterId |
JobMasterId.fromUuidOrNull(UUID uuid)
If the given uuid is null, this returns null, otherwise a JobMasterId that corresponds to the
UUID, via
JobMasterId(UUID) . |
static JobMasterId |
JobMasterId.generate()
Generates a new random JobMasterId.
|
Constructor and Description |
---|
JobMaster(RpcService rpcService,
JobMasterId jobMasterId,
JobMasterConfiguration jobMasterConfiguration,
ResourceID resourceId,
JobGraph jobGraph,
HighAvailabilityServices highAvailabilityService,
SlotPoolServiceSchedulerFactory slotPoolServiceSchedulerFactory,
JobManagerSharedServices jobManagerSharedServices,
HeartbeatServices heartbeatServices,
JobManagerJobMetricGroupFactory jobMetricGroupFactory,
OnCompletionActions jobCompletionActions,
FatalErrorHandler fatalErrorHandler,
ClassLoader userCodeLoader,
ShuffleMaster<?> shuffleMaster,
PartitionTrackerFactory partitionTrackerFactory,
ExecutionDeploymentTracker executionDeploymentTracker,
ExecutionDeploymentReconciler.Factory executionDeploymentReconcilerFactory,
BlocklistHandler.Factory blocklistHandlerFactory,
long initializationTimestamp) |
RpcTaskManagerGateway(TaskExecutorGateway taskExecutorGateway,
JobMasterId jobMasterId) |
Modifier and Type | Method and Description |
---|---|
void |
SlotPool.start(JobMasterId jobMasterId,
String newJobManagerAddress,
ComponentMainThreadExecutor jmMainThreadScheduledExecutor) |
void |
DeclarativeSlotPoolService.start(JobMasterId jobMasterId,
String address,
ComponentMainThreadExecutor mainThreadExecutor) |
void |
SlotPoolService.start(JobMasterId jobMasterId,
String address,
ComponentMainThreadExecutor mainThreadExecutor)
Start the encapsulated slot pool implementation.
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<JobMasterId> |
DefaultJobLeaderIdService.getLeaderId(JobID jobId) |
CompletableFuture<JobMasterId> |
JobLeaderIdService.getLeaderId(JobID jobId)
Get the leader's
JobMasterId future for the given job. |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Acknowledge> |
ResourceManager.declareRequiredResources(JobMasterId jobMasterId,
ResourceRequirements resourceRequirements,
Time timeout) |
CompletableFuture<Acknowledge> |
ResourceManagerGateway.declareRequiredResources(JobMasterId jobMasterId,
ResourceRequirements resourceRequirements,
Time timeout)
Declares the absolute resource requirements for a job.
|
protected void |
ResourceManager.jobLeaderLostLeadership(JobID jobId,
JobMasterId oldJobMasterId) |
void |
JobLeaderIdActions.jobLeaderLostLeadership(JobID jobId,
JobMasterId oldJobMasterId)
Callback when a monitored job leader lost its leadership.
|
CompletableFuture<RegistrationResponse> |
ResourceManager.registerJobMaster(JobMasterId jobMasterId,
ResourceID jobManagerResourceId,
String jobManagerAddress,
JobID jobId,
Time timeout) |
CompletableFuture<RegistrationResponse> |
ResourceManagerGateway.registerJobMaster(JobMasterId jobMasterId,
ResourceID jobMasterResourceId,
String jobMasterAddress,
JobID jobId,
Time timeout)
Register a
JobMaster at the resource manager. |
Modifier and Type | Method and Description |
---|---|
JobMasterId |
JobManagerRegistration.getJobMasterId() |
Modifier and Type | Method and Description |
---|---|
JobMasterId |
JobTable.Connection.getJobMasterId() |
Modifier and Type | Method and Description |
---|---|
void |
JobLeaderListener.jobManagerLostLeadership(JobID jobId,
JobMasterId jobMasterId)
Callback if the job leader for the job with the given job id lost its leadership.
|
CompletableFuture<Acknowledge> |
TaskExecutorGatewayDecoratorBase.submitTask(TaskDeploymentDescriptor tdd,
JobMasterId jobMasterId,
Time timeout) |
CompletableFuture<Acknowledge> |
TaskExecutor.submitTask(TaskDeploymentDescriptor tdd,
JobMasterId jobMasterId,
Time timeout) |
CompletableFuture<Acknowledge> |
TaskExecutorGateway.submitTask(TaskDeploymentDescriptor tdd,
JobMasterId jobMasterId,
Time timeout)
Submit a
Task to the TaskExecutor . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.