@NotThreadSafe public final class ReplicateDefinition extends AbstractVoidPlanDefinition<ReplicateConfig,SerializableVoid>
Constructor and Description |
---|
ReplicateDefinition()
Constructs a new
ReplicateDefinition . |
Modifier and Type | Method and Description |
---|---|
Class<ReplicateConfig> |
getJobConfigClass() |
SerializableVoid |
runTask(ReplicateConfig config,
SerializableVoid arg,
RunTaskContext context)
Runs the task in the executor.
|
Set<Pair<WorkerInfo,SerializableVoid>> |
selectExecutors(ReplicateConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context)
Selects the workers to run the task.
|
join
public ReplicateDefinition()
ReplicateDefinition
.public Class<ReplicateConfig> getJobConfigClass()
JobConfig
public Set<Pair<WorkerInfo,SerializableVoid>> selectExecutors(ReplicateConfig 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(ReplicateConfig config, SerializableVoid arg, RunTaskContext context) throws Exception
config
- the job configurationarg
- the arguments passed incontext
- the context containing information used to execute a taskException
- if any error occursCopyright © 2023. All Rights Reserved.