Package | Description |
---|---|
alluxio.job | |
alluxio.master.job |
Modifier and Type | Method and Description |
---|---|
<T extends JobConfig> |
JobDefinitionRegistry.getJobDefinition(T jobConfig)
Gets the job definition from the jTob configuration.
|
Modifier and Type | Method and Description |
---|---|
long |
JobTracker.addJob(JobConfig jobConfig,
CommandManager manager,
JobServerContext ctx,
List<WorkerInfo> workers)
Adds a job with the given
JobConfig to the job tracker. |
void |
JobMaster.cancel(long jobId)
Cancels a job.
|
static JobCoordinator |
JobCoordinator.create(CommandManager commandManager,
JobServerContext jobServerContext,
List<WorkerInfo> workerInfoList,
Long jobId,
JobConfig jobConfig,
java.util.function.Consumer<JobInfo> statusChangeCallback)
Creates a new instance of the
JobCoordinator . |
JobInfo |
JobMaster.getStatus(long jobId)
Gets information of the given job id.
|
long |
JobMaster.run(JobConfig jobConfig)
Runs a job with the given configuration.
|
Copyright © 2023. All Rights Reserved.