Package | Description |
---|---|
alluxio.job.plan | |
alluxio.job.plan.batch | |
alluxio.job.plan.migrate | |
alluxio.job.plan.persist | |
alluxio.job.plan.replicate | |
alluxio.job.plan.stress | |
alluxio.worker.job.task |
Modifier and Type | Method and Description |
---|---|
SerializableVoid |
NoopPlanDefinition.runTask(NoopPlanConfig config,
SerializableVoid args,
RunTaskContext runTaskContext) |
R |
PlanDefinition.runTask(T config,
P args,
RunTaskContext runTaskContext)
Runs the task in the executor.
|
Modifier and Type | Method and Description |
---|---|
SerializableVoid |
BatchedJobDefinition.runTask(BatchedJobConfig config,
BatchedJobDefinition.BatchedJobTask task,
RunTaskContext context) |
Modifier and Type | Method and Description |
---|---|
SerializableVoid |
MigrateDefinition.runTask(MigrateConfig config,
MigrateCommand command,
RunTaskContext context)
Runs the task in the executor.
|
Modifier and Type | Method and Description |
---|---|
SerializableVoid |
PersistDefinition.runTask(PersistConfig config,
SerializableVoid args,
RunTaskContext context) |
Modifier and Type | Method and Description |
---|---|
SerializableVoid |
MoveDefinition.runTask(MoveConfig config,
SerializableVoid args,
RunTaskContext context)
Runs the task in the executor.
|
Modifier and Type | Method and Description |
---|---|
String |
StressBenchDefinition.runTask(StressBenchConfig config,
ArrayList<String> args,
RunTaskContext runTaskContext) |
Modifier and Type | Method and Description |
---|---|
void |
TaskExecutorManager.executeTask(long jobId,
long taskId,
RunTaskCommand runTaskCommand,
RunTaskContext context)
Executes the given task.
|
Constructor and Description |
---|
TaskExecutor(long jobId,
long taskId,
RunTaskCommand runTaskCommand,
RunTaskContext context,
TaskExecutorManager taskExecutorManager)
Creates a new instance of
TaskExecutor . |
Copyright © 2023. All Rights Reserved.