Package | Description |
---|---|
alluxio.job.plan.meta | |
alluxio.job.wire | |
alluxio.master.job.plan | |
alluxio.master.job.workflow |
Modifier and Type | Method and Description |
---|---|
int |
PlanInfo.compareTo(PlanInfo other)
This method orders jobs using the time their status was last modified.
|
Constructor and Description |
---|
PlanInfo(long id,
JobConfig jobConfig,
java.util.function.Consumer<PlanInfo> statusChangeCallback)
Creates a new instance of
PlanInfo . |
Constructor and Description |
---|
PlanInfo(PlanInfo planInfo,
boolean verbose)
Constructs the plan info from the job master's internal representation of job info.
|
Modifier and Type | Method and Description |
---|---|
java.util.stream.Stream<PlanInfo> |
PlanTracker.failed() |
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 . |
Modifier and Type | Method and Description |
---|---|
void |
WorkflowTracker.onPlanStatusChange(PlanInfo planInfo)
Updates internal state of the workflows based on the updated state of a plan.
|
Copyright © 2023. All Rights Reserved.