Class SplitterBase<Input, ChildInput>

java.lang.Object

org.chenile.orchestrator.process.utils.base.SplitterBase<Input, ChildInput>

All Implemented Interfaces:

IWorker<Input>

public abstract class SplitterBase<Input, ChildInput>
extends Object
implements IWorker<Input>

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
SplitterBase()

Method Summary

Modifier and Type	Method	Description
protected abstract List<SubProcessPayload>	doStart(WorkerDto workerDto, Input input)	Implementations can call processManagerClient.splitPartiallyDone(workerDto.process.getId(), batchPayload); as many times as required.
protected SubProcessPayload	makeSubProcessPayload(ChildInput child, String childProcessType)
protected void	progressUpdate(String processId, int percent)
protected void	splitPartiallyDone(String id, List<SubProcessPayload> subProcessPayloads)
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

SplitterBase

public SplitterBase()

Method Details

start

public void start(WorkerDto workerDto,
 Input input)

Specified by:

start in interface IWorker<Input>

doStart

protected abstract List<SubProcessPayload> doStart(WorkerDto workerDto,
 Input input)

Implementations can call processManagerClient.splitPartiallyDone(workerDto.process.getId(), batchPayload); as many times as required. This would keep starting the other processes. Or else, it can return all the accumulated processes in one shot and they will be sent to the process manager along with Split Done event.

Parameters:

workerDto - - The DTO

input - - Input

Returns:

the list of sub process payloads.

splitPartiallyDone

protected void splitPartiallyDone(String id,
 List<SubProcessPayload> subProcessPayloads)

progressUpdate

protected void progressUpdate(String processId,
 int percent)

makeSubProcessPayload

protected SubProcessPayload makeSubProcessPayload(ChildInput child,
 String childProcessType)