Class AggregatorBase<Input, Output, ChildOutput>

java.lang.Object

org.chenile.orchestrator.process.utils.base.AggregatorBase<Input, Output, ChildOutput>

Type Parameters:

Input - - The process.input

Output - - The process.output

All Implemented Interfaces:

IWorker<Input>

public abstract class AggregatorBase<Input, Output, ChildOutput>
extends Object
implements IWorker<Input>

Unify all the children's outputs and make one consolidated output for the current process

Field Summary

Fields

Modifier and Type	Field	Description
private final org.slf4j.Logger	logger
private final ObjectMapper	objectMapper
(package private) ProcessManagerClient	processManagerClient

Constructor Summary

Constructors

Constructor	Description
AggregatorBase()

Method Summary

Modifier and Type	Method	Description
protected abstract Output	doStart(Output out, Input input, ChildOutput childOutput, WorkerDto workerDto, Process p)
protected void	progressUpdate(String processId, int percent)
void	start(WorkerDto workerDto, Input input)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

logger

private final org.slf4j.Logger logger

processManagerClient

@Autowired
ProcessManagerClient processManagerClient

objectMapper

private final ObjectMapper objectMapper

Constructor Details

AggregatorBase

public AggregatorBase()

Method Details

start

public void start(WorkerDto workerDto,
 Input input)

Specified by:

start in interface IWorker<Input>

progressUpdate

protected void progressUpdate(String processId,
 int percent)

doStart

protected abstract Output doStart(Output out,
 Input input,
 ChildOutput childOutput,
 WorkerDto workerDto,
 Process p)