Package | Description |
---|---|
alluxio.job.plan | |
alluxio.job.workflow | |
alluxio.master.job | |
alluxio.master.job.plan | |
alluxio.master.job.workflow |
Modifier and Type | Method and Description |
---|---|
<T extends JobConfig> |
PlanDefinitionRegistry.getJobDefinition(T jobConfig)
Gets the job definition from the job configuration.
|
Modifier and Type | Method and Description |
---|---|
WorkflowExecution |
WorkflowExecutionRegistry.getExecution(WorkflowConfig config)
Gets the
WorkflowExecution from workflow config. |
Modifier and Type | Method and Description |
---|---|
void |
JobMaster.cancel(long jobId)
Cancels a job.
|
JobInfo |
JobMaster.getStatus(long jobId)
Gets information of the given job id.
|
long |
JobMaster.run(JobConfig jobConfig)
Runs a job with the given configuration.
|
void |
JobMaster.run(JobConfig jobConfig,
long jobId)
Runs a job with the given configuration and job id.
|
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 . |
void |
PlanTracker.run(PlanConfig jobConfig,
CommandManager manager,
JobServerContext ctx,
List<WorkerInfo> workers,
long jobId)
Adds a job with the given
JobConfig to the job tracker. |
Modifier and Type | Method and Description |
---|---|
void |
WorkflowTracker.run(WorkflowConfig workflowConfig,
long jobId)
Runs a workflow with the given configuration and job id.
|
Copyright © 2023. All Rights Reserved.