All Classes and Interfaces
Class
Description
Payloads for WorkChunk state transitions.
ChunkExecutionDetails<PT extends ca.uhn.fhir.model.api.IModelJson,IT extends ca.uhn.fhir.model.api.IModelJson>
Default implementation which provides the
PartitionedUrl list for a certain operation request.IFirstJobStepWorker<PT extends ca.uhn.fhir.model.api.IModelJson,OT extends ca.uhn.fhir.model.api.IModelJson>
A service that produces pages of resource pids based on the data provided by a previous batch step.
IJobCompletionHandler<PT extends ca.uhn.fhir.model.api.IModelJson>
IJobDataSink<OT extends ca.uhn.fhir.model.api.IModelJson>
IJobParametersValidator<T extends ca.uhn.fhir.model.api.IModelJson>
This interface can be used to validate the parameters
object supplied to start a job instance.
Provides the list of
PartitionedUrl that a job should run against.Some of this is tested in
ca.uhn.hapi.fhir.batch2.test.AbstractIJobPersistenceSpecificationTest
This is a transactional interface, but we have pushed the declaration of calls that have
@Transactional(propagation = Propagation.REQUIRES_NEW) down to the implementations since we have a synchronized
wrapper that was double-creating the NEW transaction.Callback to update a JobInstance within a locked transaction.
IJobStepWorker<PT extends ca.uhn.fhir.model.api.IModelJson,IT extends ca.uhn.fhir.model.api.IModelJson,OT extends ca.uhn.fhir.model.api.IModelJson>
This interface is implemented by step workers within the Batch2 framework.
ILastJobStepWorker<PT extends ca.uhn.fhir.model.api.IModelJson,IT extends ca.uhn.fhir.model.api.IModelJson>
IReductionStepWorker<PT extends ca.uhn.fhir.model.api.IModelJson,IT extends ca.uhn.fhir.model.api.IModelJson,OT extends ca.uhn.fhir.model.api.IModelJson>
Reduction step worker.
Work Chunk api, implementing the WorkChunk state machine.
While performing cleanup, the cleanup job loads all work chunks
to examine their status.
JobCompletionDetails<PT extends ca.uhn.fhir.model.api.IModelJson>
JobDefinition<PT extends ca.uhn.fhir.model.api.IModelJson>
JobDefinition.Builder<PT extends ca.uhn.fhir.model.api.IModelJson,NIT extends ca.uhn.fhir.model.api.IModelJson>
JobDefinitionReductionStep<PT extends ca.uhn.fhir.model.api.IModelJson,IT extends ca.uhn.fhir.model.api.IModelJson,OT extends ca.uhn.fhir.model.api.IModelJson>
JobDefinitionStep<PT extends ca.uhn.fhir.model.api.IModelJson,IT extends ca.uhn.fhir.model.api.IModelJson,OT extends ca.uhn.fhir.model.api.IModelJson>
This exception indicates an unrecoverable processing failure.
This class performs regular polls of the stored jobs in order to
perform maintenance.
JobStepExecutor<PT extends ca.uhn.fhir.model.api.IModelJson,IT extends ca.uhn.fhir.model.api.IModelJson,OT extends ca.uhn.fhir.model.api.IModelJson>
JobStepExecutorOutput<PT extends ca.uhn.fhir.model.api.IModelJson,IT extends ca.uhn.fhir.model.api.IModelJson,OT extends ca.uhn.fhir.model.api.IModelJson>
When a step throws an Exception that is not a
JobExecutionFailedException,
the Smile Batch 2 framework will rethrow the exception as a JobStepFailedException.JobWorkCursor<PT extends ca.uhn.fhir.model.api.IModelJson,IT extends ca.uhn.fhir.model.api.IModelJson,OT extends ca.uhn.fhir.model.api.IModelJson>
This immutable object is produced by reconciling a work notification message to its corresponding job definition.
Represents the pair of partition and (search) url, which can be used to configure batch2 jobs.
Can be used to configure parameters for batch2 jobs.
ReductionStepDataSink<PT extends ca.uhn.fhir.model.api.IModelJson,IT extends ca.uhn.fhir.model.api.IModelJson,OT extends ca.uhn.fhir.model.api.IModelJson>
Exception that is thrown when a polling step needs to be retried at a later
time.
Return type for
IJobStepWorker.run(StepExecutionDetails, IJobDataSink)Status of a Batch2 Job Instance.
StepExecutionDetails<PT extends ca.uhn.fhir.model.api.IModelJson,IT extends ca.uhn.fhir.model.api.IModelJson>
Used as the input type for the first step
Payload for step processing.
Payload for the work-chunk completion event with the record and error counts.
The data required for the create transition.
WorkChunkData<OT extends ca.uhn.fhir.model.api.IModelJson>
Payload for the work-chunk error event including the error message, and the allowed retry count.
States for the
WorkChunk state machine.