Package | Description |
---|---|
alluxio.job.plan | |
alluxio.job.plan.batch | |
alluxio.job.plan.load | |
alluxio.job.plan.migrate | |
alluxio.job.plan.persist | |
alluxio.job.plan.replicate | |
alluxio.job.plan.transform |
Modifier and Type | Method and Description |
---|---|
SerializableVoid |
NoopPlanDefinition.runTask(NoopPlanConfig config,
SerializableVoid args,
RunTaskContext runTaskContext) |
Modifier and Type | Method and Description |
---|---|
Set<Pair<WorkerInfo,SerializableVoid>> |
NoopPlanDefinition.selectExecutors(NoopPlanConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext selectExecutorsContext) |
Modifier and Type | Method and Description |
---|---|
SerializableVoid |
NoopPlanDefinition.runTask(NoopPlanConfig config,
SerializableVoid args,
RunTaskContext runTaskContext) |
Modifier and Type | Method and Description |
---|---|
String |
AbstractVoidPlanDefinition.join(T config,
Map<WorkerInfo,SerializableVoid> taskResults) |
Modifier and Type | Method and Description |
---|---|
SerializableVoid |
BatchedJobDefinition.runTask(BatchedJobConfig config,
BatchedJobDefinition.BatchedJobTask task,
RunTaskContext context) |
Modifier and Type | Method and Description |
---|---|
SerializableVoid |
LoadDefinition.runTask(LoadConfig config,
ArrayList<LoadDefinition.LoadTask> tasks,
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 |
---|---|
Set<Pair<WorkerInfo,SerializableVoid>> |
PersistDefinition.selectExecutors(PersistConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context) |
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.
|
SerializableVoid |
SetReplicaDefinition.runTask(SetReplicaConfig config,
SetReplicaTask task,
RunTaskContext context)
Runs the task in the executor.
|
Modifier and Type | Method and Description |
---|---|
Set<Pair<WorkerInfo,SerializableVoid>> |
MoveDefinition.selectExecutors(MoveConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext 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 |
---|---|
SerializableVoid |
CompactDefinition.runTask(CompactConfig config,
ArrayList<CompactTask> tasks,
RunTaskContext context) |
Copyright © 2023. All Rights Reserved.