Package | Description |
---|---|
alluxio.job.plan | |
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 |
---|---|
Set<Pair<WorkerInfo,P>> |
PlanDefinition.selectExecutors(T config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext selectExecutorsContext)
Selects the workers to run the task.
|
Modifier and Type | Method and Description |
---|---|
Set<Pair<WorkerInfo,ArrayList<LoadDefinition.LoadTask>>> |
LoadDefinition.selectExecutors(LoadConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context) |
Modifier and Type | Method and Description |
---|---|
Set<Pair<WorkerInfo,ArrayList<MigrateCommand>>> |
MigrateDefinition.selectExecutors(MigrateConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context)
Selects the workers to run the task.
|
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 |
---|---|
Set<Pair<WorkerInfo,SerializableVoid>> |
EvictDefinition.selectExecutors(EvictConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context) |
Set<Pair<WorkerInfo,SerializableVoid>> |
MoveDefinition.selectExecutors(MoveConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context) |
Set<Pair<WorkerInfo,SerializableVoid>> |
ReplicateDefinition.selectExecutors(ReplicateConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context) |
Modifier and Type | Method and Description |
---|---|
Set<Pair<WorkerInfo,ArrayList<CompactTask>>> |
CompactDefinition.selectExecutors(CompactConfig config,
List<WorkerInfo> jobWorkers,
SelectExecutorsContext context) |
Copyright © 2023. All Rights Reserved.