Package ca.uhn.fhir.batch2.coordinator

Class ReductionStepExecutorServiceImpl

java.lang.Object

ca.uhn.fhir.batch2.coordinator.ReductionStepExecutorServiceImpl

All Implemented Interfaces:

IReductionStepExecutorService, IHasScheduledJobs

public class ReductionStepExecutorServiceImpl
extends Object
implements IReductionStepExecutorService, IHasScheduledJobs

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ReductionStepExecutorServiceImpl.ReductionStepExecutorScheduledJob

Field Summary

Fields

Modifier and Type	Field	Description
static final String	SCHEDULED_JOB_ID

Constructor Summary

Constructors

Constructor	Description
ReductionStepExecutorServiceImpl(IJobPersistence theJobPersistence, IHapiTransactionService theTransactionService, JobDefinitionRegistry theJobDefinitionRegistry)	Constructor

Method Summary

Modifier and Type	Method	Description
void	reducerPass()
void	scheduleJobs(ISchedulerService theSchedulerService)
void	shutdown()
void	start()
void	triggerReductionStep(String theInstanceId, JobWorkCursor<?,?,?> theJobWorkCursor)

Methods inherited from class java.lang.Object

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

Field Details

SCHEDULED_JOB_ID

public static final String SCHEDULED_JOB_ID

Constructor Details

ReductionStepExecutorServiceImpl

public ReductionStepExecutorServiceImpl(IJobPersistence theJobPersistence,
 IHapiTransactionService theTransactionService,
 JobDefinitionRegistry theJobDefinitionRegistry)

Constructor

Method Details

start

@EventListener(org.springframework.context.event.ContextRefreshedEvent.class)
public void start()

shutdown

@EventListener(org.springframework.context.event.ContextClosedEvent.class)
public void shutdown()

triggerReductionStep

public void triggerReductionStep(String theInstanceId,
 JobWorkCursor<?,?,?> theJobWorkCursor)

Specified by:

triggerReductionStep in interface IReductionStepExecutorService

reducerPass

public void reducerPass()

Specified by:

reducerPass in interface IReductionStepExecutorService

scheduleJobs

public void scheduleJobs(ISchedulerService theSchedulerService)

Specified by:

scheduleJobs in interface IHasScheduledJobs