@NotThreadSafe public final class PersistDefinition extends AbstractVoidPlanDefinition<PersistConfig,SerializableVoid>
Constructor and Description |
---|
PersistDefinition()
Constructs a new
PersistDefinition . |
Modifier and Type | Method and Description |
---|---|
Class<PersistConfig> |
getJobConfigClass() |
SerializableVoid |
runTask(PersistConfig config,
SerializableVoid args,
RunTaskContext context)
Runs the task in the executor.
|
Set<Pair<WorkerInfo,SerializableVoid>> |
selectExecutors(PersistConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context)
Selects the workers to run the task.
|
join
public PersistDefinition()
PersistDefinition
.public Set<Pair<WorkerInfo,SerializableVoid>> selectExecutors(PersistConfig config, List<WorkerInfo> jobWorkerInfoList, SelectExecutorsContext context) throws Exception
PlanDefinition
config
- the job configurationjobWorkerInfoList
- the list of available workers' informationcontext
- the context containing information used to select executorsException
- if any error occurspublic SerializableVoid runTask(PersistConfig config, SerializableVoid args, RunTaskContext context) throws Exception
PlanDefinition
config
- the job configurationargs
- the arguments passed incontext
- the context containing information used to execute a taskException
- if any error occurspublic Class<PersistConfig> getJobConfigClass()
JobConfig
Copyright © 2023. All Rights Reserved.