Modifier and Type | Method and Description |
---|---|
Set<Pair<WorkerInfo,SerializableVoid>> |
NoopPlanDefinition.selectExecutors(NoopPlanConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext selectExecutorsContext) |
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,BatchedJobDefinition.BatchedJobTask>> |
BatchedJobDefinition.selectExecutors(BatchedJobConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context) |
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,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<String>>> |
StressBenchDefinition.selectExecutors(StressBenchConfig 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.