Package | Description |
---|---|
alluxio.master.job.plan |
Modifier and Type | Method and Description |
---|---|
static PlanCoordinator |
PlanCoordinator.create(CommandManager commandManager,
JobServerContext jobServerContext,
List<WorkerInfo> workerInfoList,
Long jobId,
JobConfig jobConfig,
java.util.function.Consumer<PlanInfo> statusChangeCallback)
Creates a new instance of the
PlanCoordinator . |
PlanCoordinator |
PlanTracker.getCoordinator(long jobId)
Gets a
PlanCoordinator associated with the given job Id. |
Modifier and Type | Method and Description |
---|---|
Collection<PlanCoordinator> |
PlanTracker.coordinators()
A collection of all
PlanCoordinator currently tracked by the job master. |
Copyright © 2023. All Rights Reserved.