Package | Description |
---|---|
alluxio.job.plan | |
alluxio.job.workflow | |
alluxio.master.job | |
alluxio.master.job.plan | |
alluxio.master.job.tracker | |
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.
|
Status |
JobMaster.getCmdStatus(long jobControlId)
Get command status.
|
CmdStatusBlock |
JobMaster.getCmdStatusDetailed(long jobControlId) |
Set<String> |
JobMaster.getFailedPaths(long jobControlId) |
JobInfo |
JobMaster.getStatus(long jobId)
Gets information of the given job id (verbose = True).
|
JobInfo |
JobMaster.getStatus(long jobId,
boolean verbose)
Gets information of the given job id.
|
List<Long> |
JobMaster.listCmds(ListAllPOptions options) |
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.
|
long |
JobMaster.submit(CmdConfig cmdConfig)
Submit a job with the given configuration.
|
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 |
---|---|
Set<Long> |
CmdJobTracker.findCmdIds(List<Status> statusList) |
Set<String> |
CmdJobTracker.findFailedPaths(long jobControlId) |
Status |
CmdJobTracker.getCmdStatus(long jobControlId)
Get status information for a CMD.
|
CmdStatusBlock |
CmdJobTracker.getCmdStatusBlock(long jobControlId)
Get a cmdStatusBlock information.
|
void |
CmdJobTracker.run(CmdConfig cmdConfig,
long jobControlId)
Run the PlanTracker to trigger a Cmd job based on CmdConfig.
|
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.