Package | Description |
---|---|
alluxio.job | |
alluxio.master.job.plan | |
alluxio.worker.job.command |
Modifier and Type | Class and Description |
---|---|
class |
RunTaskContext
A context which contains useful information that can be used when running a task on a job worker.
|
class |
SelectExecutorsContext
A context containing useful parameters for the job master to use when selecting the worker
that a job should execute on.
|
Constructor and Description |
---|
RunTaskContext(long jobId,
long taskId,
JobServerContext jobServerContext)
Creates an instance of
RunTaskContext . |
SelectExecutorsContext(long jobId,
JobServerContext jobServerContext)
Creates a new instance of
SelectExecutorsContext . |
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. |
Constructor and Description |
---|
CommandHandlingExecutor(JobServerContext jobServerContext,
TaskExecutorManager taskExecutorManager,
JobMasterClient masterClient,
WorkerNetAddress workerNetAddress)
Creates a new instance of
CommandHandlingExecutor . |
Copyright © 2023. All Rights Reserved.