Index (HAPI FHIR JPA Server - Batch2 Task Processor 7.4.0 API)

A B C D E F G H I J L M N O P Q R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

accept(WorkChunkData<OT>) - Method in interface ca.uhn.fhir.batch2.api.IJobDataSink: Step workers may call this 0..* times in order to provide output work chunks that will be passed to subsequent steps.
accept(WorkChunkData<OT>) - Method in class ca.uhn.fhir.batch2.coordinator.ReductionStepDataSink
accept(OT) - Method in interface ca.uhn.fhir.batch2.api.IJobDataSink: Step workers may call this 0..* times in order to provide output work chunks that will be passed to subsequent steps.
addAttributesToCurrentSpan(String, int, String, String, String) - Static method in class ca.uhn.fhir.batch2.util.BatchJobOpenTelemetryUtils
addChunk(WorkChunk) - Method in class ca.uhn.fhir.batch2.maintenance.JobChunkProgressAccumulator
addChunk(WorkChunk) - Method in class ca.uhn.fhir.batch2.progress.InstanceProgress
addFailedChunkId(WorkChunk) - Method in class ca.uhn.fhir.batch2.coordinator.ReductionStepChunkProcessingResponse
addFinalReducerStep(String, String, Class<OT>, IReductionStepWorker<PT, NIT, OT>) - Method in class ca.uhn.fhir.batch2.model.JobDefinition.Builder
addFirstStep(String, String, Class<OT>, IJobStepWorker<PT, VoidModel, OT>) - Method in class ca.uhn.fhir.batch2.model.JobDefinition.Builder: Adds a processing step for this job.
addIntermediateStep(String, String, Class<OT>, IJobStepWorker<PT, NIT, OT>) - Method in class ca.uhn.fhir.batch2.model.JobDefinition.Builder: Adds a processing step for this job.
addJobDefinition(JobDefinition<PT>) - Method in class ca.uhn.fhir.batch2.coordinator.JobDefinitionRegistry
addJobDefinitionIfNotRegistered(JobDefinition<PT>) - Method in class ca.uhn.fhir.batch2.coordinator.JobDefinitionRegistry: Add a job definition only if it is not registered
addLastStep(String, String, IJobStepWorker<PT, NIT, VoidModel>) - Method in class ca.uhn.fhir.batch2.model.JobDefinition.Builder: Adds a processing step for this job.
addPartitionedUrl(PartitionedUrl) - Method in class ca.uhn.fhir.batch2.jobs.parameters.PartitionedUrlJobParameters
addSuccessfulChunkId(WorkChunk) - Method in class ca.uhn.fhir.batch2.coordinator.ReductionStepChunkProcessingResponse
addTypedPid(String, Long) - Method in class ca.uhn.fhir.batch2.jobs.chunk.ResourceIdListWorkChunkJson
addUrl(String) - Method in class ca.uhn.fhir.batch2.jobs.parameters.PartitionedUrlJobParameters
advanceJobStepAndUpdateChunkStatus(String, String, boolean) - Method in interface ca.uhn.fhir.batch2.api.IJobPersistence: Atomically advance the given job to the given step and change the status of all QUEUED and GATE_WAITING chunks in the next step to READY
asFinalCursor() - Method in class ca.uhn.fhir.batch2.model.JobWorkCursor

B

BaseBatch2Config - Class in ca.uhn.fhir.batch2.config
BaseBatch2Config() - Constructor for class ca.uhn.fhir.batch2.config.BaseBatch2Config
BaseWorkChunkEvent - Class in ca.uhn.fhir.batch2.model: Payloads for WorkChunk state transitions.
BaseWorkChunkEvent(String) - Constructor for class ca.uhn.fhir.batch2.model.BaseWorkChunkEvent
BATCH_START_DATE - Static variable in class ca.uhn.fhir.batch2.util.Batch2Utils: The batch 2 system assumes that all records have a start date later than this date.
batch2JobCoordinator(JobDefinitionRegistry, BatchJobSender, WorkChunkProcessor, IJobMaintenanceService, IHapiTransactionService) - Method in class ca.uhn.fhir.batch2.config.BaseBatch2Config
batch2JobDefinitionRegistry() - Method in class ca.uhn.fhir.batch2.config.BaseBatch2Config
batch2JobMaintenanceService(ISchedulerService, JobDefinitionRegistry, JpaStorageSettings, BatchJobSender, WorkChunkProcessor, IReductionStepExecutorService) - Method in class ca.uhn.fhir.batch2.config.BaseBatch2Config
batch2JobRegisterer() - Method in class ca.uhn.fhir.batch2.config.BaseBatch2Config
Batch2JobRegisterer - Class in ca.uhn.fhir.batch2.config
Batch2JobRegisterer() - Constructor for class ca.uhn.fhir.batch2.config.Batch2JobRegisterer
batch2ProcessingChannelProducer(IChannelFactory) - Method in class ca.uhn.fhir.batch2.config.BaseBatch2Config
batch2ProcessingChannelReceiver(IChannelFactory) - Method in class ca.uhn.fhir.batch2.config.BaseBatch2Config
Batch2Utils - Class in ca.uhn.fhir.batch2.util
BatchJobOpenTelemetryUtils - Class in ca.uhn.fhir.batch2.util
batchJobSender() - Method in class ca.uhn.fhir.batch2.config.BaseBatch2Config
BatchJobSender - Class in ca.uhn.fhir.batch2.channel
BatchJobSender(IChannelProducer) - Constructor for class ca.uhn.fhir.batch2.channel.BatchJobSender
build() - Method in class ca.uhn.fhir.batch2.model.JobDefinition.Builder

C

ca.uhn.fhir.batch2 - package ca.uhn.fhir.batch2: Our distributed batch processing library.
ca.uhn.fhir.batch2.api - package ca.uhn.fhir.batch2.api: This package contains the APIs used in the Batch2 framework.
ca.uhn.fhir.batch2.channel - package ca.uhn.fhir.batch2.channel
ca.uhn.fhir.batch2.config - package ca.uhn.fhir.batch2.config
ca.uhn.fhir.batch2.coordinator - package ca.uhn.fhir.batch2.coordinator
ca.uhn.fhir.batch2.jobs.chunk - package ca.uhn.fhir.batch2.jobs.chunk
ca.uhn.fhir.batch2.jobs.parameters - package ca.uhn.fhir.batch2.jobs.parameters
ca.uhn.fhir.batch2.jobs.step - package ca.uhn.fhir.batch2.jobs.step
ca.uhn.fhir.batch2.maintenance - package ca.uhn.fhir.batch2.maintenance
ca.uhn.fhir.batch2.model - package ca.uhn.fhir.batch2.model
ca.uhn.fhir.batch2.progress - package ca.uhn.fhir.batch2.progress
ca.uhn.fhir.batch2.util - package ca.uhn.fhir.batch2.util
calculateAndStoreInstanceProgress(String) - Method in class ca.uhn.fhir.batch2.progress.JobInstanceProgressCalculator
calculateInstanceProgress(String) - Method in class ca.uhn.fhir.batch2.progress.JobInstanceProgressCalculator
calculateNewStatus(boolean) - Method in class ca.uhn.fhir.batch2.progress.InstanceProgress: Transitions from IN_PROGRESS/ERRORED based on chunk statuses.
cancelInstance(String) - Method in interface ca.uhn.fhir.batch2.api.IJobCoordinator
cancelInstance(String) - Method in interface ca.uhn.fhir.batch2.api.IJobPersistence: Marks an instance as cancelled
cancelInstance(String) - Method in class ca.uhn.fhir.batch2.coordinator.JobCoordinatorImpl
CANCELLED - Enum constant in enum ca.uhn.fhir.batch2.model.StatusEnum: Task has been cancelled by the user.
CHANNEL_NAME - Static variable in class ca.uhn.fhir.batch2.config.BaseBatch2Config
ChunkExecutionDetails<PT extends ca.uhn.fhir.model.api.IModelJson,IT extends ca.uhn.fhir.model.api.IModelJson> - Class in ca.uhn.fhir.batch2.api
ChunkExecutionDetails(IT, PT, String, String) - Constructor for class ca.uhn.fhir.batch2.api.ChunkExecutionDetails
ChunkOutcome - Class in ca.uhn.fhir.batch2.model
ChunkOutcome(ChunkOutcome.Status) - Constructor for class ca.uhn.fhir.batch2.model.ChunkOutcome
ChunkOutcome.Status - Enum in ca.uhn.fhir.batch2.model
ChunkProducer - Class in ca.uhn.fhir.batch2.jobs.step
ChunkProducer(IBatch2DaoSvc) - Constructor for class ca.uhn.fhir.batch2.jobs.step.ChunkProducer
ChunkRangeJson - Class in ca.uhn.fhir.batch2.jobs.chunk
ChunkRangeJson() - Constructor for class ca.uhn.fhir.batch2.jobs.chunk.ChunkRangeJson
ChunkRangeJson(Date, Date) - Constructor for class ca.uhn.fhir.batch2.jobs.chunk.ChunkRangeJson
COMPLETED - Enum constant in enum ca.uhn.fhir.batch2.model.StatusEnum: Task completed successfully
COMPLETED - Enum constant in enum ca.uhn.fhir.batch2.model.WorkChunkStatusEnum: The state of workchunks that have finished their job's step.
completionHandler(IJobCompletionHandler<PT>) - Method in class ca.uhn.fhir.batch2.model.JobDefinition.Builder: Supplies an optional callback that will be invoked when the job is complete
consume(ChunkExecutionDetails<PT, IT>) - Method in interface ca.uhn.fhir.batch2.api.IReductionStepWorker: If an exception is thrown, the workchunk will be marked as failed.
createReductionStepDetails(P1, I1, JobInstance) - Static method in class ca.uhn.fhir.batch2.api.StepExecutionDetails: Create and returns a step execution details for a reduction job
CreateResult(String, String) - Constructor for class ca.uhn.fhir.batch2.api.IJobPersistence.CreateResult
createWorkChunk(WorkChunk) - Method in interface ca.uhn.fhir.batch2.api.IJobPersistence
currentStep - Variable in class ca.uhn.fhir.batch2.model.JobWorkCursor

D

DefaultJobPartitionProvider - Class in ca.uhn.fhir.batch2.coordinator: Default implementation which provides the PartitionedUrl list for a certain operation request.
DefaultJobPartitionProvider(FhirContext, IRequestPartitionHelperSvc, MatchUrlService) - Constructor for class ca.uhn.fhir.batch2.coordinator.DefaultJobPartitionProvider
DefaultJobPartitionProvider(IRequestPartitionHelperSvc) - Constructor for class ca.uhn.fhir.batch2.coordinator.DefaultJobPartitionProvider
deleteChunksAndMarkInstanceAsChunksPurged(String) - Method in interface ca.uhn.fhir.batch2.api.IJobPersistence: Deletes all work chunks associated with the instance
deleteInstanceAndChunks(String) - Method in interface ca.uhn.fhir.batch2.api.IJobPersistence: Deletes the instance and all associated work chunks
doExecution(JobWorkCursor<PT, IT, OT>, JobInstance, WorkChunk) - Method in class ca.uhn.fhir.batch2.coordinator.WorkChunkProcessor: Execute the work chunk.
doUpdate(JobInstance) - Method in interface ca.uhn.fhir.batch2.api.IJobPersistence.JobInstanceUpdateCallback: Modify theInstance within a write-lock transaction.

E

enableMaintenancePass(boolean) - Method in interface ca.uhn.fhir.batch2.api.IJobMaintenanceService: This is only to be called in a testing environment to ensure state changes are controlled.
enableMaintenancePass(boolean) - Method in class ca.uhn.fhir.batch2.maintenance.JobMaintenanceServiceImpl
enqueueWorkChunkForProcessing(String, Consumer<Integer>) - Method in interface ca.uhn.fhir.batch2.api.IJobPersistence
equals(Object) - Method in class ca.uhn.fhir.batch2.jobs.chunk.TypedPidJson
equals(Object) - Method in class ca.uhn.fhir.batch2.jobs.parameters.PartitionedUrl
equals(Object) - Method in class ca.uhn.fhir.batch2.model.BaseWorkChunkEvent
equals(Object) - Method in class ca.uhn.fhir.batch2.model.WorkChunkCompletionEvent
equals(Object) - Method in class ca.uhn.fhir.batch2.model.WorkChunkCreateEvent
equals(Object) - Method in class ca.uhn.fhir.batch2.model.WorkChunkErrorEvent
ERRORED - Enum constant in enum ca.uhn.fhir.batch2.model.StatusEnum: Deprecated.
this is basically a synonym for IN_PROGRESS - display should use the presence of an error message on the instance to indicate that there has been a transient error.
ERRORED - Enum constant in enum ca.uhn.fhir.batch2.model.WorkChunkStatusEnum: A transient state on retry when a chunk throws an error, but hasn't FAILED yet.
errorHandler(IJobCompletionHandler<PT>) - Method in class ca.uhn.fhir.batch2.model.JobDefinition.Builder: Supplies an optional callback that will be invoked if the job fails
execute(JobExecutionContext) - Method in class ca.uhn.fhir.batch2.coordinator.ReductionStepExecutorServiceImpl.ReductionStepExecutorScheduledJob
execute(JobExecutionContext) - Method in class ca.uhn.fhir.batch2.maintenance.JobMaintenanceServiceImpl.JobMaintenanceScheduledJob
executeStep() - Method in class ca.uhn.fhir.batch2.coordinator.JobStepExecutor

F

FAILED - Enum constant in enum ca.uhn.fhir.batch2.model.ChunkOutcome.Status
FAILED - Enum constant in enum ca.uhn.fhir.batch2.model.StatusEnum: Task has failed and is known to be unrecoverable.
FAILED - Enum constant in enum ca.uhn.fhir.batch2.model.WorkChunkStatusEnum: Chunk has failed with a non-retriable error, or has run out of retry attempts.
fetchAllJobInstances(JobInstanceFetchRequest) - Method in interface ca.uhn.fhir.batch2.api.IJobCoordinator: Fetches all job instances tht meet the FetchRequest criteria
fetchAllJobInstances(JobInstanceFetchRequest) - Method in class ca.uhn.fhir.batch2.coordinator.JobCoordinatorImpl
fetchAllWorkChunkMetadataForJobInStates(Pageable, String, Set<WorkChunkStatusEnum>) - Method in interface ca.uhn.fhir.batch2.api.IJobPersistence: Fetches an iterator that retrieves WorkChunkMetadata from the db.
fetchAllWorkChunksForStepStream(String, String) - Method in interface ca.uhn.fhir.batch2.api.IJobPersistence: Fetch all chunks with data for a given instance for a given step id - read-only.
fetchAllWorkChunksForStepStream(String, String) - Method in interface ca.uhn.fhir.batch2.api.IWorkChunkPersistence: Fetch all chunks with data for a given instance for a given step id
fetchAllWorkChunksIterator(String, boolean) - Method in interface ca.uhn.fhir.batch2.api.IJobPersistence: Fetch all chunks for a given instance.
fetchAllWorkChunksIterator(String, boolean) - Method in interface ca.uhn.fhir.batch2.api.IWorkChunkPersistence: Fetch all chunks for a given instance.
fetchInstance(String) - Method in interface ca.uhn.fhir.batch2.api.IJobPersistence: Fetch an instance
fetchInstances(int, int) - Method in interface ca.uhn.fhir.batch2.api.IJobPersistence: Fetch all instances
fetchInstances(FetchJobInstancesRequest, int, int) - Method in interface ca.uhn.fhir.batch2.api.IJobPersistence: Fetches any existing jobs matching provided request parameters
fetchInstances(String, Set<StatusEnum>, Date, Pageable) - Method in interface ca.uhn.fhir.batch2.api.IJobPersistence
fetchInstancesByJobDefinitionId(String, int, int) - Method in interface ca.uhn.fhir.batch2.api.IJobPersistence: Fetch all job instances for a given job definition id
fetchInstancesByJobDefinitionIdAndStatus(String, Set<StatusEnum>, int, int) - Method in interface ca.uhn.fhir.batch2.api.IJobPersistence
fetchJobInstances(JobInstanceFetchRequest) - Method in interface ca.uhn.fhir.batch2.api.IJobPersistence: Fetches all job instances based on the JobFetchRequest
FetchJobInstancesRequest - Class in ca.uhn.fhir.batch2.model
FetchJobInstancesRequest(String, String) - Constructor for class ca.uhn.fhir.batch2.model.FetchJobInstancesRequest
FetchJobInstancesRequest(String, String, StatusEnum...) - Constructor for class ca.uhn.fhir.batch2.model.FetchJobInstancesRequest
fetchRecentInstances(int, int) - Method in interface ca.uhn.fhir.batch2.api.IJobPersistence: Fetch instances ordered by myCreateTime DESC
fetchResourceIdStream(ChunkRangeJson) - Method in class ca.uhn.fhir.batch2.jobs.step.ChunkProducer
fetchResourceIdStream(IT) - Method in interface ca.uhn.fhir.batch2.jobs.step.IIdChunkProducer
fetchResourceIdStream(Date, Date, RequestPartitionId, IT) - Method in interface ca.uhn.fhir.batch2.jobs.step.IIdChunkProducer: Deprecated.
FINALIZE - Enum constant in enum ca.uhn.fhir.batch2.model.StatusEnum: For reduction steps
firstChunk(JobDefinition<?>, String) - Static method in class ca.uhn.fhir.batch2.model.WorkChunkCreateEvent: Creates the WorkChunkCreateEvent for the first chunk of a job.
firstStepNotification(JobDefinition<?>, String, String) - Static method in class ca.uhn.fhir.batch2.model.JobWorkNotification
firstStepProducedNothing() - Method in class ca.uhn.fhir.batch2.coordinator.ReductionStepDataSink
forceMaintenancePass() - Method in interface ca.uhn.fhir.batch2.api.IJobMaintenanceService: Forces a second maintenance run.
forceMaintenancePass() - Method in class ca.uhn.fhir.batch2.maintenance.JobMaintenanceServiceImpl
fromInstanceId(String) - Static method in class ca.uhn.fhir.batch2.model.JobInstance
fromJobDefinition(JobDefinition<?>) - Static method in class ca.uhn.fhir.batch2.model.JobInstance
fromJobDefinitionAndRequestedStepId(JobDefinition<PT>, String) - Static method in class ca.uhn.fhir.batch2.model.JobWorkCursor

G

GATE_WAITING - Enum constant in enum ca.uhn.fhir.batch2.model.WorkChunkStatusEnum: The initial state all workchunks start in for gated jobs.
gatedExecution() - Method in class ca.uhn.fhir.batch2.model.JobDefinition.Builder: If this is set, the framework will wait for all work chunks to be processed for an individual step before moving on to beginning processing on the next step.
GenerateRangeChunksStep<PT extends PartitionedUrlJobParameters> - Class in ca.uhn.fhir.batch2.jobs.step
GenerateRangeChunksStep() - Constructor for class ca.uhn.fhir.batch2.jobs.step.GenerateRangeChunksStep
getAllPartitions() - Method in class ca.uhn.fhir.batch2.coordinator.DefaultJobPartitionProvider
getBatchSize() - Method in class ca.uhn.fhir.batch2.jobs.parameters.PartitionedUrlJobParameters
getChunkId() - Method in class ca.uhn.fhir.batch2.api.ChunkExecutionDetails
getChunkId() - Method in class ca.uhn.fhir.batch2.api.StepExecutionDetails: Returns the work chunk ID being executed
getChunkId() - Method in class ca.uhn.fhir.batch2.model.BaseWorkChunkEvent
getChunkId() - Method in class ca.uhn.fhir.batch2.model.JobWorkNotification
getChunkIdsWithStatus(String, String, WorkChunkStatusEnum...) - Method in class ca.uhn.fhir.batch2.maintenance.JobChunkProgressAccumulator
getCombinedRecordsProcessed() - Method in interface ca.uhn.fhir.batch2.api.IJobInstance
getCombinedRecordsProcessed() - Method in class ca.uhn.fhir.batch2.model.JobInstance
getCombinedRecordsProcessedPerSecond() - Method in interface ca.uhn.fhir.batch2.api.IJobInstance
getCombinedRecordsProcessedPerSecond() - Method in class ca.uhn.fhir.batch2.model.JobInstance
getCompletionHandler() - Method in class ca.uhn.fhir.batch2.model.JobDefinition
getConcurrentConsumers() - Method in class ca.uhn.fhir.batch2.config.BaseBatch2Config: Can be overridden
getCreateTime() - Method in interface ca.uhn.fhir.batch2.api.IJobInstance
getCreateTime() - Method in class ca.uhn.fhir.batch2.model.JobInstance
getCreateTime() - Method in class ca.uhn.fhir.batch2.model.WorkChunk
getCurrentGatedStepId() - Method in interface ca.uhn.fhir.batch2.api.IJobInstance
getCurrentGatedStepId() - Method in class ca.uhn.fhir.batch2.model.JobInstance
getCurrentStep() - Method in class ca.uhn.fhir.batch2.model.JobWorkCursor
getCurrentStepId() - Method in class ca.uhn.fhir.batch2.model.JobWorkCursor
getData() - Method in class ca.uhn.fhir.batch2.api.ChunkExecutionDetails
getData() - Method in class ca.uhn.fhir.batch2.api.StepExecutionDetails: Returns the data associated with this step execution.
getData() - Method in class ca.uhn.fhir.batch2.model.ListResult
getData() - Method in class ca.uhn.fhir.batch2.model.WorkChunk
getData() - Method in class ca.uhn.fhir.batch2.model.WorkChunkData
getData(Class<T>) - Method in class ca.uhn.fhir.batch2.model.WorkChunk
getDataSink() - Method in class ca.uhn.fhir.batch2.coordinator.JobStepExecutorOutput
getDataSink(JobWorkCursor<PT, IT, OT>, JobDefinition<PT>, String) - Method in class ca.uhn.fhir.batch2.coordinator.WorkChunkProcessor: Get the correct datasink for the cursor/job provided.
getDistinctWorkChunkStatesForJobAndStep(String, String) - Method in interface ca.uhn.fhir.batch2.api.IJobPersistence: Returns set of all distinct states for the specified job instance id and step id.
getEnd() - Method in class ca.uhn.fhir.batch2.jobs.chunk.ChunkRangeJson
getEndedStatuses() - Static method in enum ca.uhn.fhir.batch2.model.StatusEnum: Statuses that represent a job that has ended.
getEndTime() - Method in interface ca.uhn.fhir.batch2.api.IJobInstance
getEndTime() - Method in class ca.uhn.fhir.batch2.model.JobInstance
getEndTime() - Method in class ca.uhn.fhir.batch2.model.WorkChunk
getErrorCount() - Method in interface ca.uhn.fhir.batch2.api.IJobInstance
getErrorCount() - Method in class ca.uhn.fhir.batch2.model.JobInstance
getErrorCount() - Method in class ca.uhn.fhir.batch2.model.WorkChunk
getErrorHandler() - Method in class ca.uhn.fhir.batch2.model.JobDefinition
getErrorMessage() - Method in interface ca.uhn.fhir.batch2.api.IJobInstance
getErrorMessage() - Method in class ca.uhn.fhir.batch2.model.JobInstance
getErrorMessage() - Method in class ca.uhn.fhir.batch2.model.WorkChunk
getErrorMsg() - Method in class ca.uhn.fhir.batch2.model.WorkChunkErrorEvent
getEstimatedTimeRemaining() - Method in interface ca.uhn.fhir.batch2.api.IJobInstance
getEstimatedTimeRemaining() - Method in class ca.uhn.fhir.batch2.model.JobInstance
getFailedChunksIds() - Method in class ca.uhn.fhir.batch2.coordinator.ReductionStepChunkProcessingResponse
getFirstStepId() - Method in class ca.uhn.fhir.batch2.model.JobDefinition
getId() - Method in class ca.uhn.fhir.batch2.model.WorkChunkMetadata
getIncompleteStatuses() - Static method in enum ca.uhn.fhir.batch2.model.StatusEnum: Statuses that represent a job that has not yet completed.
getInputType() - Method in class ca.uhn.fhir.batch2.model.JobDefinitionStep
getInstance() - Method in class ca.uhn.fhir.batch2.api.JobCompletionDetails: Returns the job instance ID being executed
getInstance() - Method in class ca.uhn.fhir.batch2.api.StepExecutionDetails: Returns the job instance ID being executed
getInstance(String) - Method in interface ca.uhn.fhir.batch2.api.IJobCoordinator: Fetch details about a job instance
getInstance(String) - Method in class ca.uhn.fhir.batch2.coordinator.JobCoordinatorImpl
getInstanceId() - Method in class ca.uhn.fhir.batch2.api.ChunkExecutionDetails
getInstanceId() - Method in interface ca.uhn.fhir.batch2.api.IJobInstance
getInstanceId() - Method in class ca.uhn.fhir.batch2.coordinator.ReductionStepDataSink
getInstanceId() - Method in class ca.uhn.fhir.batch2.model.JobInstance
getInstanceId() - Method in class ca.uhn.fhir.batch2.model.JobWorkNotification
getInstanceId() - Method in class ca.uhn.fhir.batch2.model.WorkChunkMetadata
getInstances(int, int) - Method in interface ca.uhn.fhir.batch2.api.IJobCoordinator: Fetch all job instances
getInstances(int, int) - Method in class ca.uhn.fhir.batch2.coordinator.JobCoordinatorImpl
getInstancesbyJobDefinitionIdAndEndedStatus(String, Boolean, int, int) - Method in interface ca.uhn.fhir.batch2.api.IJobCoordinator
getInstancesbyJobDefinitionIdAndEndedStatus(String, Boolean, int, int) - Method in class ca.uhn.fhir.batch2.coordinator.JobCoordinatorImpl
getJobDefinition() - Method in class ca.uhn.fhir.batch2.model.FetchJobInstancesRequest
getJobDefinition() - Method in class ca.uhn.fhir.batch2.model.JobWorkCursor
getJobDefinition(String, int) - Method in class ca.uhn.fhir.batch2.coordinator.JobDefinitionRegistry
getJobDefinitionId() - Method in class ca.uhn.fhir.batch2.coordinator.ReductionStepDataSink
getJobDefinitionId() - Method in class ca.uhn.fhir.batch2.model.JobDefinition
getJobDefinitionId() - Method in class ca.uhn.fhir.batch2.model.JobInstance
getJobDefinitionId() - Method in class ca.uhn.fhir.batch2.model.JobInstanceStartRequest
getJobDefinitionId() - Method in class ca.uhn.fhir.batch2.model.JobWorkNotification
getJobDefinitionId() - Method in class ca.uhn.fhir.batch2.model.WorkChunkMetadata
getJobDefinitionIds() - Method in class ca.uhn.fhir.batch2.coordinator.JobDefinitionRegistry
getJobDefinitionOrThrowException(JobInstance) - Method in class ca.uhn.fhir.batch2.coordinator.JobDefinitionRegistry
getJobDefinitionOrThrowException(String, int) - Method in class ca.uhn.fhir.batch2.coordinator.JobDefinitionRegistry
getJobDefinitionVersion() - Method in interface ca.uhn.fhir.batch2.api.IJobInstance
getJobDefinitionVersion() - Method in class ca.uhn.fhir.batch2.model.JobDefinition
getJobDefinitionVersion() - Method in class ca.uhn.fhir.batch2.model.JobInstance
getJobDefinitionVersion() - Method in class ca.uhn.fhir.batch2.model.JobWorkNotification
getJobDefinitionVersion() - Method in class ca.uhn.fhir.batch2.model.WorkChunkMetadata
getJobDefinitionVersions(String) - Method in class ca.uhn.fhir.batch2.coordinator.JobDefinitionRegistry
getJobDescription() - Method in class ca.uhn.fhir.batch2.model.JobDefinition
getJobInstancesByJobDefinitionId(String, int, int) - Method in interface ca.uhn.fhir.batch2.api.IJobCoordinator: Fetches all jobs by job definition id
getJobInstancesByJobDefinitionId(String, int, int) - Method in class ca.uhn.fhir.batch2.coordinator.JobCoordinatorImpl
getJobInstancesByJobDefinitionIdAndStatuses(String, Set<StatusEnum>, int, int) - Method in interface ca.uhn.fhir.batch2.api.IJobCoordinator: Fetches all job instances by job definition id and statuses
getJobInstancesByJobDefinitionIdAndStatuses(String, Set<StatusEnum>, int, int) - Method in class ca.uhn.fhir.batch2.coordinator.JobCoordinatorImpl
getJobStepWorker() - Method in class ca.uhn.fhir.batch2.model.JobDefinitionStep
getLatestJobDefinition(String) - Method in class ca.uhn.fhir.batch2.coordinator.JobDefinitionRegistry
getMessage() - Method in class ca.uhn.fhir.batch2.api.JobOperationResultJson
getNewStatus() - Method in class ca.uhn.fhir.batch2.progress.InstanceProgress
getNextPollDuration() - Method in exception ca.uhn.fhir.batch2.api.RetryChunkLaterException
getNextPollTime() - Method in class ca.uhn.fhir.batch2.model.WorkChunk
getNextStates() - Method in enum ca.uhn.fhir.batch2.model.StatusEnum: States this state may transotion to.
getNextStates() - Method in enum ca.uhn.fhir.batch2.model.WorkChunkStatusEnum
getNotEndedStatuses() - Static method in enum ca.uhn.fhir.batch2.model.StatusEnum: Statuses that represent a job that has not ended.
getOperation() - Method in class ca.uhn.fhir.batch2.api.JobOperationResultJson
getOutputType() - Method in class ca.uhn.fhir.batch2.model.JobDefinitionStep
getParameters() - Method in class ca.uhn.fhir.batch2.api.ChunkExecutionDetails
getParameters() - Method in class ca.uhn.fhir.batch2.api.JobCompletionDetails: Returns the parameters associated with this job instance.
getParameters() - Method in class ca.uhn.fhir.batch2.api.StepExecutionDetails: Returns the parameters associated with this job instance.
getParameters() - Method in class ca.uhn.fhir.batch2.model.FetchJobInstancesRequest
getParameters() - Method in class ca.uhn.fhir.batch2.model.JobInstance
getParameters() - Method in class ca.uhn.fhir.batch2.model.JobInstanceStartRequest
getParameters(Class<T>) - Method in class ca.uhn.fhir.batch2.model.JobInstance
getParameters(Class<T>) - Method in class ca.uhn.fhir.batch2.model.JobInstanceStartRequest
getParametersType() - Method in class ca.uhn.fhir.batch2.model.JobDefinition
getParametersValidator() - Method in class ca.uhn.fhir.batch2.model.JobDefinition
getPartitionedUrls() - Method in class ca.uhn.fhir.batch2.jobs.parameters.PartitionedUrlJobParameters
getPartitionedUrls(RequestDetails, List<String>) - Method in interface ca.uhn.fhir.batch2.api.IJobPartitionProvider: Provides the list of PartitionedUrl to run job steps against, based on the request that initiates the job and the urls that it's configured with.
getPartitionedUrls(RequestDetails, List<String>) - Method in class ca.uhn.fhir.batch2.coordinator.DefaultJobPartitionProvider
getPartitionId() - Method in class ca.uhn.fhir.batch2.jobs.chunk.ChunkRangeJson
getPartitions(RequestDetails, String) - Method in interface ca.uhn.fhir.batch2.api.IJobPartitionProvider: Provides the list of partitions to run job steps against, based on the request that initiates the job.
getPartitions(RequestDetails, String) - Method in class ca.uhn.fhir.batch2.coordinator.DefaultJobPartitionProvider
getPayload() - Method in class ca.uhn.fhir.batch2.model.JobWorkNotificationJsonMessage
getPid() - Method in class ca.uhn.fhir.batch2.jobs.chunk.TypedPidJson
getPollAttempts() - Method in class ca.uhn.fhir.batch2.model.WorkChunk
getPriorStates() - Method in enum ca.uhn.fhir.batch2.model.StatusEnum: States that may transition to this state.
getPriorStates() - Method in enum ca.uhn.fhir.batch2.model.WorkChunkStatusEnum
getProgress() - Method in interface ca.uhn.fhir.batch2.api.IJobInstance
getProgress() - Method in class ca.uhn.fhir.batch2.model.JobInstance
getReadyChunks() - Method in class ca.uhn.fhir.batch2.maintenance.JobInstanceProcessor
getRecentInstances(int, int) - Method in interface ca.uhn.fhir.batch2.api.IJobCoordinator: Fetch recent job instances
getRecentInstances(int, int) - Method in class ca.uhn.fhir.batch2.coordinator.JobCoordinatorImpl
getRecordsProcessed() - Method in class ca.uhn.fhir.batch2.api.RunOutcome
getRecordsProcessed() - Method in class ca.uhn.fhir.batch2.model.WorkChunk
getRecordsProcessed() - Method in class ca.uhn.fhir.batch2.model.WorkChunkCompletionEvent
getRecoveredErrorCount() - Method in class ca.uhn.fhir.batch2.coordinator.ReductionStepDataSink
getRecoveredErrorCount() - Method in class ca.uhn.fhir.batch2.model.WorkChunkCompletionEvent
getRecoveredWarning() - Method in class ca.uhn.fhir.batch2.coordinator.ReductionStepDataSink
getRecoveredWarningMessage() - Method in interface ca.uhn.fhir.batch2.api.IWarningProcessor
getRecoveredWarningMessage() - Method in class ca.uhn.fhir.batch2.model.WorkChunkCompletionEvent
getReport() - Method in interface ca.uhn.fhir.batch2.api.IJobInstance
getReport() - Method in class ca.uhn.fhir.batch2.model.JobInstance
getRequestPartitionId() - Method in class ca.uhn.fhir.batch2.jobs.chunk.ResourceIdListWorkChunkJson
getRequestPartitionId() - Method in class ca.uhn.fhir.batch2.jobs.parameters.PartitionedUrl
getRequestPartitionId() - Method in class ca.uhn.fhir.batch2.jobs.parameters.PartitionedUrlJobParameters
getResourcePersistentIds(IIdHelperService<T>) - Method in class ca.uhn.fhir.batch2.jobs.chunk.ResourceIdListWorkChunkJson
getResourceType() - Method in class ca.uhn.fhir.batch2.jobs.chunk.ChunkRangeJson
getResourceType() - Method in class ca.uhn.fhir.batch2.jobs.chunk.TypedPidJson
getResourceType(int) - Method in class ca.uhn.fhir.batch2.jobs.chunk.ResourceIdListWorkChunkJson
getSequence() - Method in class ca.uhn.fhir.batch2.model.WorkChunkMetadata
getStart() - Method in class ca.uhn.fhir.batch2.jobs.chunk.ChunkRangeJson
getStartTime() - Method in interface ca.uhn.fhir.batch2.api.IJobInstance
getStartTime() - Method in class ca.uhn.fhir.batch2.model.JobInstance
getStartTime() - Method in class ca.uhn.fhir.batch2.model.WorkChunk
getStatus() - Method in interface ca.uhn.fhir.batch2.api.IJobInstance
getStatus() - Method in class ca.uhn.fhir.batch2.model.ChunkOutcome
getStatus() - Method in class ca.uhn.fhir.batch2.model.JobInstance
getStatus() - Method in class ca.uhn.fhir.batch2.model.WorkChunkMetadata
getStatuses() - Method in class ca.uhn.fhir.batch2.model.FetchJobInstancesRequest
getStepById(String) - Method in class ca.uhn.fhir.batch2.model.JobDefinition
getStepDescription() - Method in class ca.uhn.fhir.batch2.model.JobDefinitionStep
getStepId() - Method in class ca.uhn.fhir.batch2.model.JobDefinitionStep
getStepIndex(String) - Method in class ca.uhn.fhir.batch2.model.JobDefinition
getSteps() - Method in class ca.uhn.fhir.batch2.model.JobDefinition
getSuccess() - Method in class ca.uhn.fhir.batch2.api.JobOperationResultJson
getSuccessfulChunkIds() - Method in class ca.uhn.fhir.batch2.coordinator.ReductionStepChunkProcessingResponse
getTargetStep() - Method in class ca.uhn.fhir.batch2.coordinator.ReductionStepDataSink
getTargetStepId() - Method in class ca.uhn.fhir.batch2.model.JobWorkNotification
getTargetStepId() - Method in class ca.uhn.fhir.batch2.model.WorkChunkMetadata
getTotalElapsedMillis() - Method in interface ca.uhn.fhir.batch2.api.IJobInstance
getTotalElapsedMillis() - Method in class ca.uhn.fhir.batch2.model.JobInstance
getTriggeringClientId() - Method in class ca.uhn.fhir.batch2.model.JobInstance
getTriggeringUsername() - Method in class ca.uhn.fhir.batch2.model.JobInstance
getUpdateTime() - Method in class ca.uhn.fhir.batch2.model.JobInstance
getUpdateTime() - Method in class ca.uhn.fhir.batch2.model.WorkChunk
getUrl() - Method in class ca.uhn.fhir.batch2.jobs.chunk.ChunkRangeJson
getUrl() - Method in class ca.uhn.fhir.batch2.jobs.parameters.PartitionedUrl
getUrls() - Method in class ca.uhn.fhir.batch2.jobs.parameters.PartitionedUrlJobParameters
getWarningMessage() - Method in class ca.uhn.fhir.batch2.model.WorkChunk
getWarningMessages() - Method in interface ca.uhn.fhir.batch2.api.IJobInstance
getWarningMessages() - Method in class ca.uhn.fhir.batch2.model.JobInstance
getWorkChunk() - Method in class ca.uhn.fhir.batch2.api.StepExecutionDetails
getWorkChunkCount() - Method in class ca.uhn.fhir.batch2.coordinator.ReductionStepDataSink

H

hasAssociatedWorkChunk() - Method in class ca.uhn.fhir.batch2.api.StepExecutionDetails: Returns true if there's a workchunk to store data to.
hasExactlyOneChunk() - Method in class ca.uhn.fhir.batch2.coordinator.ReductionStepDataSink
hasFailedChunkIds() - Method in class ca.uhn.fhir.batch2.coordinator.ReductionStepChunkProcessingResponse
hasGatedStep() - Method in class ca.uhn.fhir.batch2.model.JobInstance
hashCode() - Method in class ca.uhn.fhir.batch2.jobs.chunk.TypedPidJson
hashCode() - Method in class ca.uhn.fhir.batch2.jobs.parameters.PartitionedUrl
hashCode() - Method in class ca.uhn.fhir.batch2.model.BaseWorkChunkEvent
hashCode() - Method in class ca.uhn.fhir.batch2.model.WorkChunkCompletionEvent
hashCode() - Method in class ca.uhn.fhir.batch2.model.WorkChunkCreateEvent
hashCode() - Method in class ca.uhn.fhir.batch2.model.WorkChunkErrorEvent
hasNewStatus() - Method in class ca.uhn.fhir.batch2.progress.InstanceProgress
hasSuccessfulChunksIds() - Method in class ca.uhn.fhir.batch2.coordinator.ReductionStepChunkProcessingResponse

I

ID_MAX_LENGTH - Static variable in class ca.uhn.fhir.batch2.model.JobDefinition
IFirstJobStepWorker<PT extends ca.uhn.fhir.model.api.IModelJson,OT extends ca.uhn.fhir.model.api.IModelJson> - Interface in ca.uhn.fhir.batch2.api
IIdChunkProducer<IT extends ChunkRangeJson> - Interface in ca.uhn.fhir.batch2.jobs.step: 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> - Interface in ca.uhn.fhir.batch2.api
IJobCoordinator - Interface in ca.uhn.fhir.batch2.api
IJobDataSink<OT extends ca.uhn.fhir.model.api.IModelJson> - Interface in ca.uhn.fhir.batch2.api
IJobInstance - Interface in ca.uhn.fhir.batch2.api
IJobMaintenanceService - Interface in ca.uhn.fhir.batch2.api
IJobParametersValidator<T extends ca.uhn.fhir.model.api.IModelJson> - Interface in ca.uhn.fhir.batch2.api: This interface can be used to validate the parameters object supplied to start a job instance.
IJobPartitionProvider - Interface in ca.uhn.fhir.batch2.api: Provides the list of PartitionedUrl that a job should run against.
IJobPersistence - Interface in ca.uhn.fhir.batch2.api: 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.
IJobPersistence.CreateResult - Class in ca.uhn.fhir.batch2.api
IJobPersistence.JobInstanceUpdateCallback - Interface in ca.uhn.fhir.batch2.api: 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> - Interface in ca.uhn.fhir.batch2.api: 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> - Interface in ca.uhn.fhir.batch2.api
IN_PROGRESS - Enum constant in enum ca.uhn.fhir.batch2.model.StatusEnum: Task is current executing
IN_PROGRESS - Enum constant in enum ca.uhn.fhir.batch2.model.WorkChunkStatusEnum: The state of workchunks that are doing work.
instanceId - Variable in class ca.uhn.fhir.batch2.model.WorkChunkCreateEvent
InstanceProgress - Class in ca.uhn.fhir.batch2.progress
InstanceProgress() - Constructor for class ca.uhn.fhir.batch2.progress.InstanceProgress
INSTANCES_PER_PASS - Static variable in class ca.uhn.fhir.batch2.maintenance.JobMaintenanceServiceImpl
IReductionStepExecutorService - Interface in ca.uhn.fhir.batch2.api
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> - Interface in ca.uhn.fhir.batch2.api: Reduction step worker.
isAReadyState() - Method in enum ca.uhn.fhir.batch2.model.WorkChunkStatusEnum
isCancellable() - Method in enum ca.uhn.fhir.batch2.model.StatusEnum
isCancelled() - Method in interface ca.uhn.fhir.batch2.api.IJobInstance
isCancelled() - Method in class ca.uhn.fhir.batch2.model.JobInstance
isEmpty() - Method in class ca.uhn.fhir.batch2.coordinator.JobDefinitionRegistry
isEnded() - Method in enum ca.uhn.fhir.batch2.model.StatusEnum
isFastTracking() - Method in interface ca.uhn.fhir.batch2.api.IJobInstance
isFastTracking() - Method in class ca.uhn.fhir.batch2.model.JobInstance
isFinalStep() - Method in class ca.uhn.fhir.batch2.model.JobWorkCursor
isFinished() - Method in class ca.uhn.fhir.batch2.model.JobInstance
isFirstStep - Variable in class ca.uhn.fhir.batch2.model.JobWorkCursor
isFirstStep() - Method in class ca.uhn.fhir.batch2.model.JobWorkCursor
isGatedExecution - Variable in class ca.uhn.fhir.batch2.model.WorkChunkCreateEvent
isGatedExecution() - Method in class ca.uhn.fhir.batch2.model.JobDefinition
isIncomplete() - Method in enum ca.uhn.fhir.batch2.model.StatusEnum
isIncomplete() - Method in enum ca.uhn.fhir.batch2.model.WorkChunkStatusEnum
isLastStepReduction() - Method in class ca.uhn.fhir.batch2.model.JobDefinition
isLegalStateTransition(StatusEnum, StatusEnum) - Static method in enum ca.uhn.fhir.batch2.model.StatusEnum
isPendingCancellationRequest() - Method in class ca.uhn.fhir.batch2.model.JobInstance
isReductionStep() - Method in class ca.uhn.fhir.batch2.model.JobDefinitionReductionStep
isReductionStep() - Method in class ca.uhn.fhir.batch2.model.JobDefinitionStep
isReductionStep() - Method in class ca.uhn.fhir.batch2.model.JobWorkCursor
isReductionWorkChunk() - Method in class ca.uhn.fhir.batch2.model.WorkChunk: Returns true if the workchunk is a reduction workchunk; false otherwise
isRunning() - Method in class ca.uhn.fhir.batch2.model.JobInstance: Returns true if the job instance is in: StatusEnum.IN_PROGRESS StatusEnum.FINALIZE and is not cancelled
isSuccessful() - Method in class ca.uhn.fhir.batch2.coordinator.JobStepExecutorOutput
isSuccessful() - Method in class ca.uhn.fhir.batch2.coordinator.ReductionStepChunkProcessingResponse
isUseCache() - Method in class ca.uhn.fhir.batch2.model.JobInstanceStartRequest
isWorkChunksPurged() - Method in interface ca.uhn.fhir.batch2.api.IJobInstance
isWorkChunksPurged() - Method in class ca.uhn.fhir.batch2.model.JobInstance
IUrlListValidator - Interface in ca.uhn.fhir.batch2.jobs.parameters
IWarningProcessor - Interface in ca.uhn.fhir.batch2.api
IWorkChunkPersistence - Interface in ca.uhn.fhir.batch2.api: Work Chunk api, implementing the WorkChunk state machine.

J

JOB_STEP_EXECUTION_SPAN_NAME - Static variable in class ca.uhn.fhir.batch2.util.BatchJobOpenTelemetryUtils
JobChunkProgressAccumulator - Class in ca.uhn.fhir.batch2.maintenance: While performing cleanup, the cleanup job loads all work chunks to examine their status.
JobChunkProgressAccumulator() - Constructor for class ca.uhn.fhir.batch2.maintenance.JobChunkProgressAccumulator
jobComplete(JobCompletionDetails<PT>) - Method in interface ca.uhn.fhir.batch2.api.IJobCompletionHandler
JobCompletionDetails<PT extends ca.uhn.fhir.model.api.IModelJson> - Class in ca.uhn.fhir.batch2.api
JobCompletionDetails(PT, JobInstance) - Constructor for class ca.uhn.fhir.batch2.api.JobCompletionDetails
JobCoordinatorImpl - Class in ca.uhn.fhir.batch2.coordinator
JobCoordinatorImpl(BatchJobSender, IChannelReceiver, IJobPersistence, JobDefinitionRegistry, WorkChunkProcessor, IJobMaintenanceService, IHapiTransactionService) - Constructor for class ca.uhn.fhir.batch2.coordinator.JobCoordinatorImpl: Constructor
jobDefinition - Variable in class ca.uhn.fhir.batch2.model.JobWorkCursor
JobDefinition<PT extends ca.uhn.fhir.model.api.IModelJson> - Class in ca.uhn.fhir.batch2.model
JobDefinition.Builder<PT extends ca.uhn.fhir.model.api.IModelJson,NIT extends ca.uhn.fhir.model.api.IModelJson> - Class in ca.uhn.fhir.batch2.model
jobDefinitionId - Variable in class ca.uhn.fhir.batch2.model.WorkChunkCreateEvent
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> - Class in ca.uhn.fhir.batch2.model
JobDefinitionReductionStep(String, String, IReductionStepWorker<PT, IT, OT>, Class<IT>, Class<OT>) - Constructor for class ca.uhn.fhir.batch2.model.JobDefinitionReductionStep
JobDefinitionRegistry - Class in ca.uhn.fhir.batch2.coordinator
JobDefinitionRegistry() - Constructor for class ca.uhn.fhir.batch2.coordinator.JobDefinitionRegistry
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> - Class in ca.uhn.fhir.batch2.model
JobDefinitionStep(String, String, IJobStepWorker<PT, IT, OT>, Class<IT>, Class<OT>) - Constructor for class ca.uhn.fhir.batch2.model.JobDefinitionStep
jobDefinitionVersion - Variable in class ca.uhn.fhir.batch2.model.WorkChunkCreateEvent
JobExecutionFailedException - Exception in ca.uhn.fhir.batch2.api: This exception indicates an unrecoverable processing failure.
JobExecutionFailedException(String) - Constructor for exception ca.uhn.fhir.batch2.api.JobExecutionFailedException: Constructor
JobExecutionFailedException(String, Throwable) - Constructor for exception ca.uhn.fhir.batch2.api.JobExecutionFailedException: Constructor
JobInstance - Class in ca.uhn.fhir.batch2.model
JobInstance() - Constructor for class ca.uhn.fhir.batch2.model.JobInstance: Constructor
JobInstance(JobInstance) - Constructor for class ca.uhn.fhir.batch2.model.JobInstance: Copy constructor
jobInstanceId - Variable in class ca.uhn.fhir.batch2.api.IJobPersistence.CreateResult
JobInstanceProcessor - Class in ca.uhn.fhir.batch2.maintenance
JobInstanceProcessor(IJobPersistence, BatchJobSender, String, JobChunkProgressAccumulator, IReductionStepExecutorService, JobDefinitionRegistry) - Constructor for class ca.uhn.fhir.batch2.maintenance.JobInstanceProcessor
JobInstanceProgressCalculator - Class in ca.uhn.fhir.batch2.progress
JobInstanceProgressCalculator(IJobPersistence, JobChunkProgressAccumulator, JobDefinitionRegistry) - Constructor for class ca.uhn.fhir.batch2.progress.JobInstanceProgressCalculator
JobInstanceStartRequest - Class in ca.uhn.fhir.batch2.model
JobInstanceStartRequest() - Constructor for class ca.uhn.fhir.batch2.model.JobInstanceStartRequest: Constructor
JobInstanceStartRequest(JobInstanceStartRequest) - Constructor for class ca.uhn.fhir.batch2.model.JobInstanceStartRequest: Copy constructor
JobInstanceStartRequest(String, IModelJson) - Constructor for class ca.uhn.fhir.batch2.model.JobInstanceStartRequest: Constructor
JobInstanceStatusUpdater - Class in ca.uhn.fhir.batch2.progress
JobInstanceStatusUpdater(JobDefinitionRegistry) - Constructor for class ca.uhn.fhir.batch2.progress.JobInstanceStatusUpdater
JobMaintenanceScheduledJob() - Constructor for class ca.uhn.fhir.batch2.maintenance.JobMaintenanceServiceImpl.JobMaintenanceScheduledJob
JobMaintenanceServiceImpl - Class in ca.uhn.fhir.batch2.maintenance: This class performs regular polls of the stored jobs in order to perform maintenance.
JobMaintenanceServiceImpl(ISchedulerService, IJobPersistence, JpaStorageSettings, JobDefinitionRegistry, BatchJobSender, WorkChunkProcessor, IReductionStepExecutorService) - Constructor for class ca.uhn.fhir.batch2.maintenance.JobMaintenanceServiceImpl: Constructor
JobMaintenanceServiceImpl.JobMaintenanceScheduledJob - Class in ca.uhn.fhir.batch2.maintenance
JobOperationResultJson - Class in ca.uhn.fhir.batch2.api
JobOperationResultJson() - Constructor for class ca.uhn.fhir.batch2.api.JobOperationResultJson
jobPartitionProvider(FhirContext, IRequestPartitionHelperSvc, MatchUrlService) - Method in class ca.uhn.fhir.batch2.config.BaseBatch2Config
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> - Class in ca.uhn.fhir.batch2.coordinator
JobStepExecutorFactory - Class in ca.uhn.fhir.batch2.coordinator
JobStepExecutorFactory(IJobPersistence, BatchJobSender, WorkChunkProcessor, IJobMaintenanceService, JobDefinitionRegistry) - Constructor for class ca.uhn.fhir.batch2.coordinator.JobStepExecutorFactory
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> - Class in ca.uhn.fhir.batch2.coordinator
JobStepExecutorOutput(boolean, BaseDataSink<PT, IT, OT>) - Constructor for class ca.uhn.fhir.batch2.coordinator.JobStepExecutorOutput
jobStepExecutorService(BatchJobSender) - Method in class ca.uhn.fhir.batch2.config.BaseBatch2Config
JobStepFailedException - Exception in ca.uhn.fhir.batch2.api: When a step throws an Exception that is not a JobExecutionFailedException, the Smile Batch 2 framework will rethrow the exception as a JobStepFailedException.
JobStepFailedException(String, Throwable) - Constructor for exception ca.uhn.fhir.batch2.api.JobStepFailedException: Constructor
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> - Class in ca.uhn.fhir.batch2.model: This immutable object is produced by reconciling a work notification message to its corresponding job definition.
JobWorkCursor(JobDefinition<PT>, boolean, JobDefinitionStep<PT, IT, OT>, JobDefinitionStep<PT, OT, ?>) - Constructor for class ca.uhn.fhir.batch2.model.JobWorkCursor
JobWorkNotification - Class in ca.uhn.fhir.batch2.model
JobWorkNotification() - Constructor for class ca.uhn.fhir.batch2.model.JobWorkNotification
JobWorkNotification(JobInstance, String, String) - Constructor for class ca.uhn.fhir.batch2.model.JobWorkNotification
JobWorkNotification(String, int, String, String, String) - Constructor for class ca.uhn.fhir.batch2.model.JobWorkNotification
JobWorkNotificationJsonMessage - Class in ca.uhn.fhir.batch2.model
JobWorkNotificationJsonMessage() - Constructor for class ca.uhn.fhir.batch2.model.JobWorkNotificationJsonMessage: Constructor
JobWorkNotificationJsonMessage(JobWorkNotification) - Constructor for class ca.uhn.fhir.batch2.model.JobWorkNotificationJsonMessage: Constructor

L

ListResult<T> - Class in ca.uhn.fhir.batch2.model
ListResult(List<T>) - Constructor for class ca.uhn.fhir.batch2.model.ListResult
LoadIdsStep<PT extends PartitionedUrlJobParameters> - Class in ca.uhn.fhir.batch2.jobs.step
LoadIdsStep(IBatch2DaoSvc) - Constructor for class ca.uhn.fhir.batch2.jobs.step.LoadIdsStep

M

MAINTENANCE_TRIGGER_RUN_WITHOUT_SCHEDULER_TIMEOUT - Static variable in class ca.uhn.fhir.batch2.maintenance.JobMaintenanceServiceImpl
markInstanceAsStatusWhenStatusIn(String, StatusEnum, Set<StatusEnum>) - Method in interface ca.uhn.fhir.batch2.api.IJobPersistence
markWorkChunksWithStatusAndWipeData(String, List<String>, WorkChunkStatusEnum, String) - Method in interface ca.uhn.fhir.batch2.api.IWorkChunkPersistence: Marks all work chunks with the provided status and erases the data
MAX_BATCH_OF_IDS - Static variable in class ca.uhn.fhir.batch2.jobs.step.ResourceIdListStep
MAX_CHUNK_ERROR_COUNT - Static variable in class ca.uhn.fhir.batch2.coordinator.WorkChunkProcessor: This retry only works if your channel producer supports retries on message processing exceptions.
myChunkId - Variable in class ca.uhn.fhir.batch2.model.BaseWorkChunkEvent
myFhirContext - Variable in class ca.uhn.fhir.batch2.coordinator.DefaultJobPartitionProvider
myJobDefinitionId - Variable in class ca.uhn.fhir.batch2.coordinator.ReductionStepDataSink
myJobStepWorker - Variable in class ca.uhn.fhir.batch2.model.JobDefinitionStep
myRequestPartitionHelper - Variable in class ca.uhn.fhir.batch2.coordinator.DefaultJobPartitionProvider

N

newBuilder() - Static method in class ca.uhn.fhir.batch2.model.JobDefinition
newFailure(String, String) - Static method in class ca.uhn.fhir.batch2.api.JobOperationResultJson
newJobStepExecutor(JobInstance, WorkChunk, JobWorkCursor<PT, IT, OT>) - Method in class ca.uhn.fhir.batch2.coordinator.JobStepExecutorFactory
newSuccess(String, String) - Static method in class ca.uhn.fhir.batch2.api.JobOperationResultJson
nextStep - Variable in class ca.uhn.fhir.batch2.model.JobWorkCursor

O

onChunkDequeued(String) - Method in interface ca.uhn.fhir.batch2.api.IJobPersistence: Move from QUEUED->IN_PROGRESS when a work chunk arrives.
onCreateWithFirstChunk(JobDefinition<?>, String) - Method in interface ca.uhn.fhir.batch2.api.IJobPersistence: Create the job, and it's first chunk.
onWorkChunkCompletion(WorkChunkCompletionEvent) - Method in interface ca.uhn.fhir.batch2.api.IWorkChunkPersistence: Report success and complete the chunk.
onWorkChunkCreate(WorkChunkCreateEvent) - Method in interface ca.uhn.fhir.batch2.api.IWorkChunkPersistence: Stores a chunk of work for later retrieval.
onWorkChunkDequeue(String) - Method in interface ca.uhn.fhir.batch2.api.IWorkChunkPersistence: On arrival at a worker.
onWorkChunkError(WorkChunkErrorEvent) - Method in interface ca.uhn.fhir.batch2.api.IWorkChunkPersistence: A retryable error.
onWorkChunkFailed(String, String) - Method in interface ca.uhn.fhir.batch2.api.IWorkChunkPersistence: An unrecoverable error.
onWorkChunkPollDelay(String, Date) - Method in interface ca.uhn.fhir.batch2.api.IWorkChunkPersistence: Updates the specified Work Chunk to set the next polling interval.
ourLog - Static variable in interface ca.uhn.fhir.batch2.api.IJobPersistence

P

PartitionedUrl - Class in ca.uhn.fhir.batch2.jobs.parameters: Represents the pair of partition and (search) url, which can be used to configure batch2 jobs.
PartitionedUrl() - Constructor for class ca.uhn.fhir.batch2.jobs.parameters.PartitionedUrl
PartitionedUrlJobParameters - Class in ca.uhn.fhir.batch2.jobs.parameters: Can be used to configure parameters for batch2 jobs.
PartitionedUrlJobParameters() - Constructor for class ca.uhn.fhir.batch2.jobs.parameters.PartitionedUrlJobParameters
partitionUrl(String, RequestDetails) - Method in class ca.uhn.fhir.batch2.jobs.parameters.UrlPartitioner
POLL_WAITING - Enum constant in enum ca.uhn.fhir.batch2.model.WorkChunkStatusEnum: A workchunk status for workchunks that are doing long-polling work that will not complete in a reasonably short amount of time
process() - Method in class ca.uhn.fhir.batch2.maintenance.JobInstanceProcessor
PURGE_THRESHOLD - Static variable in class ca.uhn.fhir.batch2.maintenance.JobInstanceProcessor

Q

QUEUED - Enum constant in enum ca.uhn.fhir.batch2.model.StatusEnum: Task is waiting to execute and should begin with no intervention required.
QUEUED - Enum constant in enum ca.uhn.fhir.batch2.model.WorkChunkStatusEnum: The state of workchunks that have been sent to the queue; or of workchunks that are about to be processed in a final reduction step (these workchunks are never queued)

R

READY - Enum constant in enum ca.uhn.fhir.batch2.model.WorkChunkStatusEnum: The initial state all workchunks start in for non-gated jobs.
recoveredError(String) - Method in interface ca.uhn.fhir.batch2.api.IJobDataSink: Step workers may invoke this method to indicate that an error occurred during processing but that it was successfully recovered, or it does not need to be recovered, or at least that it does not mean that processing should stop.
recoveredError(String) - Method in class ca.uhn.fhir.batch2.coordinator.ReductionStepDataSink
recoverWarningMessage(String) - Method in interface ca.uhn.fhir.batch2.api.IWarningProcessor: Data Sink may invoke this method to indicate that an error occurred during processing in work chunks but that it is non-fatal and should be saved as a warning.
reducerPass() - Method in interface ca.uhn.fhir.batch2.api.IReductionStepExecutorService
reducerPass() - Method in class ca.uhn.fhir.batch2.coordinator.ReductionStepExecutorServiceImpl
REDUCTION_READY - Enum constant in enum ca.uhn.fhir.batch2.model.WorkChunkStatusEnum: Workchunk is ready for reduction pass.
REDUCTION_STEP_CHUNK_ID_PLACEHOLDER - Static variable in class ca.uhn.fhir.batch2.util.Batch2Utils: This is a placeholder chunkid for the reduction step to allow it to be used in the message handling
ReductionStepChunkProcessingResponse - Class in ca.uhn.fhir.batch2.coordinator
ReductionStepChunkProcessingResponse(boolean) - Constructor for class ca.uhn.fhir.batch2.coordinator.ReductionStepChunkProcessingResponse
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> - Class in ca.uhn.fhir.batch2.coordinator
ReductionStepDataSink(String, JobWorkCursor<PT, IT, OT>, IJobPersistence, JobDefinitionRegistry) - Constructor for class ca.uhn.fhir.batch2.coordinator.ReductionStepDataSink
ReductionStepExecutorScheduledJob() - Constructor for class ca.uhn.fhir.batch2.coordinator.ReductionStepExecutorServiceImpl.ReductionStepExecutorScheduledJob
reductionStepExecutorService(IJobPersistence, IHapiTransactionService, JobDefinitionRegistry) - Method in class ca.uhn.fhir.batch2.config.BaseBatch2Config
ReductionStepExecutorServiceImpl - Class in ca.uhn.fhir.batch2.coordinator
ReductionStepExecutorServiceImpl(IJobPersistence, IHapiTransactionService, JobDefinitionRegistry) - Constructor for class ca.uhn.fhir.batch2.coordinator.ReductionStepExecutorServiceImpl: Constructor
ReductionStepExecutorServiceImpl.ReductionStepExecutorScheduledJob - Class in ca.uhn.fhir.batch2.coordinator
removeJobDefinition(String, int) - Method in class ca.uhn.fhir.batch2.coordinator.JobDefinitionRegistry
ResourceIdListStep<PT extends PartitionedUrlJobParameters> - Class in ca.uhn.fhir.batch2.jobs.step
ResourceIdListStep(IIdChunkProducer<ChunkRangeJson>) - Constructor for class ca.uhn.fhir.batch2.jobs.step.ResourceIdListStep
ResourceIdListWorkChunkJson - Class in ca.uhn.fhir.batch2.jobs.chunk
ResourceIdListWorkChunkJson() - Constructor for class ca.uhn.fhir.batch2.jobs.chunk.ResourceIdListWorkChunkJson: Constructor
ResourceIdListWorkChunkJson(Collection<TypedPidJson>, RequestPartitionId) - Constructor for class ca.uhn.fhir.batch2.jobs.chunk.ResourceIdListWorkChunkJson: Constructor
RetryChunkLaterException - Exception in ca.uhn.fhir.batch2.api: Exception that is thrown when a polling step needs to be retried at a later time.
RetryChunkLaterException() - Constructor for exception ca.uhn.fhir.batch2.api.RetryChunkLaterException
RetryChunkLaterException(Duration) - Constructor for exception ca.uhn.fhir.batch2.api.RetryChunkLaterException
run(StepExecutionDetails<PT, VoidModel>, IJobDataSink<ChunkRangeJson>) - Method in class ca.uhn.fhir.batch2.jobs.step.GenerateRangeChunksStep
run(StepExecutionDetails<PT, ChunkRangeJson>, IJobDataSink<ResourceIdListWorkChunkJson>) - Method in class ca.uhn.fhir.batch2.jobs.step.LoadIdsStep
run(StepExecutionDetails<PT, ChunkRangeJson>, IJobDataSink<ResourceIdListWorkChunkJson>) - Method in class ca.uhn.fhir.batch2.jobs.step.ResourceIdListStep
run(StepExecutionDetails<PT, IT>, IJobDataSink<OT>) - Method in interface ca.uhn.fhir.batch2.api.IJobStepWorker: Executes a step
runMaintenancePass() - Method in interface ca.uhn.fhir.batch2.api.IJobMaintenanceService
runMaintenancePass() - Method in class ca.uhn.fhir.batch2.maintenance.JobMaintenanceServiceImpl
RunOutcome - Class in ca.uhn.fhir.batch2.api: Return type for IJobStepWorker.run(StepExecutionDetails, IJobDataSink)
RunOutcome(int) - Constructor for class ca.uhn.fhir.batch2.api.RunOutcome: Constructor

S

SCHEDULED_JOB_ID - Static variable in class ca.uhn.fhir.batch2.coordinator.ReductionStepExecutorServiceImpl
SCHEDULED_JOB_ID - Static variable in class ca.uhn.fhir.batch2.maintenance.JobMaintenanceServiceImpl
scheduleJobs(ISchedulerService) - Method in class ca.uhn.fhir.batch2.coordinator.ReductionStepExecutorServiceImpl
scheduleJobs(ISchedulerService) - Method in class ca.uhn.fhir.batch2.maintenance.JobMaintenanceServiceImpl
sendWorkChannelMessage(JobWorkNotification) - Method in class ca.uhn.fhir.batch2.channel.BatchJobSender
sequence - Variable in class ca.uhn.fhir.batch2.model.WorkChunkCreateEvent
serializedData - Variable in class ca.uhn.fhir.batch2.model.WorkChunkCreateEvent
setBatchSize(int) - Method in class ca.uhn.fhir.batch2.jobs.parameters.PartitionedUrlJobParameters
setCancelled(boolean) - Method in class ca.uhn.fhir.batch2.model.JobInstance
setChunkId(String) - Method in class ca.uhn.fhir.batch2.model.JobWorkNotification
setCombinedRecordsProcessed(Integer) - Method in class ca.uhn.fhir.batch2.model.JobInstance
setCombinedRecordsProcessedPerSecond(Double) - Method in class ca.uhn.fhir.batch2.model.JobInstance
setCreateTime(Date) - Method in class ca.uhn.fhir.batch2.model.JobInstance
setCreateTime(Date) - Method in class ca.uhn.fhir.batch2.model.WorkChunk
setCurrentGatedStepId(String) - Method in class ca.uhn.fhir.batch2.model.JobInstance
setData(IModelJson) - Method in class ca.uhn.fhir.batch2.model.WorkChunk
setData(String) - Method in class ca.uhn.fhir.batch2.model.WorkChunk
setEndTime(Date) - Method in class ca.uhn.fhir.batch2.model.JobInstance
setEndTime(Date) - Method in class ca.uhn.fhir.batch2.model.WorkChunk
setErrorCount(int) - Method in class ca.uhn.fhir.batch2.model.JobInstance
setErrorCount(int) - Method in class ca.uhn.fhir.batch2.model.WorkChunk
setErrorMessage(String) - Method in class ca.uhn.fhir.batch2.model.JobInstance
setErrorMessage(String) - Method in class ca.uhn.fhir.batch2.model.WorkChunk
setErrorMsg(String) - Method in class ca.uhn.fhir.batch2.model.WorkChunkErrorEvent
setEstimatedTimeRemaining(String) - Method in class ca.uhn.fhir.batch2.model.JobInstance
setFastTracking(boolean) - Method in interface ca.uhn.fhir.batch2.api.IJobInstance
setFastTracking(boolean) - Method in class ca.uhn.fhir.batch2.model.JobInstance
setId(String) - Method in class ca.uhn.fhir.batch2.model.WorkChunk
setId(String) - Method in class ca.uhn.fhir.batch2.model.WorkChunkMetadata
setInstanceId(String) - Method in class ca.uhn.fhir.batch2.model.JobInstance
setInstanceId(String) - Method in class ca.uhn.fhir.batch2.model.JobWorkNotification
setInstanceId(String) - Method in class ca.uhn.fhir.batch2.model.WorkChunk
setInstanceId(String) - Method in class ca.uhn.fhir.batch2.model.WorkChunkMetadata
setJobDefinition(JobDefinition<?>) - Method in class ca.uhn.fhir.batch2.model.JobInstance
setJobDefinition(JobInstance) - Method in class ca.uhn.fhir.batch2.coordinator.JobDefinitionRegistry
setJobDefinitionId(String) - Method in class ca.uhn.fhir.batch2.model.JobDefinition.Builder
setJobDefinitionId(String) - Method in class ca.uhn.fhir.batch2.model.JobInstance
setJobDefinitionId(String) - Method in class ca.uhn.fhir.batch2.model.JobInstanceStartRequest
setJobDefinitionId(String) - Method in class ca.uhn.fhir.batch2.model.JobWorkNotification
setJobDefinitionId(String) - Method in class ca.uhn.fhir.batch2.model.WorkChunk
setJobDefinitionId(String) - Method in class ca.uhn.fhir.batch2.model.WorkChunkMetadata
setJobDefinitionVersion(int) - Method in class ca.uhn.fhir.batch2.model.JobDefinition.Builder
setJobDefinitionVersion(int) - Method in class ca.uhn.fhir.batch2.model.JobInstance
setJobDefinitionVersion(int) - Method in class ca.uhn.fhir.batch2.model.JobWorkNotification
setJobDefinitionVersion(int) - Method in class ca.uhn.fhir.batch2.model.WorkChunk
setJobDefinitionVersion(int) - Method in class ca.uhn.fhir.batch2.model.WorkChunkMetadata
setJobDescription(String) - Method in class ca.uhn.fhir.batch2.model.JobDefinition.Builder
setMaintenanceJobFinishedCallback(Runnable) - Method in class ca.uhn.fhir.batch2.maintenance.JobMaintenanceServiceImpl
setMaintenanceJobStartedCallback(Runnable) - Method in class ca.uhn.fhir.batch2.maintenance.JobMaintenanceServiceImpl
setMessage(String) - Method in class ca.uhn.fhir.batch2.api.JobOperationResultJson
setNextPollTime(Date) - Method in class ca.uhn.fhir.batch2.model.WorkChunk
setOperation(String) - Method in class ca.uhn.fhir.batch2.api.JobOperationResultJson
setParameters(IModelJson) - Method in class ca.uhn.fhir.batch2.model.JobInstance
setParameters(IModelJson) - Method in class ca.uhn.fhir.batch2.model.JobInstanceStartRequest: Sets the parameters for the job.
setParameters(String) - Method in class ca.uhn.fhir.batch2.model.JobInstance
setParameters(String) - Method in class ca.uhn.fhir.batch2.model.JobInstanceStartRequest
setParametersType(Class<NPT>) - Method in class ca.uhn.fhir.batch2.model.JobDefinition.Builder: Sets the datatype for the parameters used by this job.
setParametersValidator(IJobParametersValidator<PT>) - Method in class ca.uhn.fhir.batch2.model.JobDefinition.Builder: Supplies a programmatic job parameters validator.
setPartitionId(RequestPartitionId) - Method in class ca.uhn.fhir.batch2.jobs.chunk.ChunkRangeJson
setPayload(JobWorkNotification) - Method in class ca.uhn.fhir.batch2.model.JobWorkNotificationJsonMessage
setPid(String) - Method in class ca.uhn.fhir.batch2.jobs.chunk.TypedPidJson
setPollAttempts(int) - Method in class ca.uhn.fhir.batch2.model.WorkChunk
setProgress(double) - Method in class ca.uhn.fhir.batch2.model.JobInstance
setRecordsProcessed(Integer) - Method in class ca.uhn.fhir.batch2.model.WorkChunk
setReport(String) - Method in class ca.uhn.fhir.batch2.model.JobInstance
setRequestPartitionId(RequestPartitionId) - Method in class ca.uhn.fhir.batch2.jobs.parameters.PartitionedUrl
setRequestPartitionId(RequestPartitionId) - Method in class ca.uhn.fhir.batch2.jobs.parameters.PartitionedUrlJobParameters
setResourceType(String) - Method in class ca.uhn.fhir.batch2.jobs.chunk.ChunkRangeJson
setResourceType(String) - Method in class ca.uhn.fhir.batch2.jobs.chunk.TypedPidJson
setScheduledJobFrequencyMillis(long) - Method in class ca.uhn.fhir.batch2.maintenance.JobMaintenanceServiceImpl
setSequence(int) - Method in class ca.uhn.fhir.batch2.model.WorkChunkMetadata
setStartTime(Date) - Method in class ca.uhn.fhir.batch2.model.JobInstance
setStartTime(Date) - Method in class ca.uhn.fhir.batch2.model.WorkChunk
setStatus(StatusEnum) - Method in class ca.uhn.fhir.batch2.model.JobInstance
setStatus(WorkChunkStatusEnum) - Method in class ca.uhn.fhir.batch2.model.WorkChunk
setStatus(WorkChunkStatusEnum) - Method in class ca.uhn.fhir.batch2.model.WorkChunkMetadata
setSuccess(Boolean) - Method in class ca.uhn.fhir.batch2.api.JobOperationResultJson
setSuccessful(boolean) - Method in class ca.uhn.fhir.batch2.coordinator.ReductionStepChunkProcessingResponse
setTargetStepId(String) - Method in class ca.uhn.fhir.batch2.model.JobWorkNotification
setTargetStepId(String) - Method in class ca.uhn.fhir.batch2.model.WorkChunk
setTargetStepId(String) - Method in class ca.uhn.fhir.batch2.model.WorkChunkMetadata
setTotalElapsedMillis(Integer) - Method in class ca.uhn.fhir.batch2.model.JobInstance
setTriggeringClientId(String) - Method in class ca.uhn.fhir.batch2.model.JobInstance
setTriggeringUsername(String) - Method in class ca.uhn.fhir.batch2.model.JobInstance
setUpdateTime(Date) - Method in class ca.uhn.fhir.batch2.model.JobInstance
setUpdateTime(Date) - Method in class ca.uhn.fhir.batch2.model.WorkChunk
setUrl(String) - Method in class ca.uhn.fhir.batch2.jobs.chunk.ChunkRangeJson
setUrl(String) - Method in class ca.uhn.fhir.batch2.jobs.parameters.PartitionedUrl
setUseCache(boolean) - Method in class ca.uhn.fhir.batch2.model.JobInstanceStartRequest
setWarningMessage(String) - Method in class ca.uhn.fhir.batch2.model.WorkChunk
setWarningMessages(String) - Method in class ca.uhn.fhir.batch2.model.JobInstance
setWarningProcessor(IWarningProcessor) - Method in interface ca.uhn.fhir.batch2.api.IJobDataSink: Step workers may invoke this method to indicate that a warning message processor
setWarningProcessor(IWarningProcessor) - Method in class ca.uhn.fhir.batch2.coordinator.ReductionStepDataSink
setWorkChunksPurged(boolean) - Method in class ca.uhn.fhir.batch2.model.JobInstance
shutdown() - Method in class ca.uhn.fhir.batch2.coordinator.ReductionStepExecutorServiceImpl
size() - Method in class ca.uhn.fhir.batch2.jobs.chunk.ResourceIdListWorkChunkJson
start() - Method in class ca.uhn.fhir.batch2.config.Batch2JobRegisterer
start() - Method in class ca.uhn.fhir.batch2.coordinator.JobCoordinatorImpl
start() - Method in class ca.uhn.fhir.batch2.coordinator.ReductionStepExecutorServiceImpl
startInstance(JobInstanceStartRequest) - Method in interface ca.uhn.fhir.batch2.api.IJobCoordinator: Deprecated, for removal: This API element is subject to removal in a future version.
Use IJobCoordinator.startInstance(RequestDetails, JobInstanceStartRequest)
startInstance(RequestDetails, JobInstanceStartRequest) - Method in interface ca.uhn.fhir.batch2.api.IJobCoordinator: Starts a new job instance
startInstance(RequestDetails, JobInstanceStartRequest) - Method in class ca.uhn.fhir.batch2.coordinator.JobCoordinatorImpl
StatusEnum - Enum in ca.uhn.fhir.batch2.model: Status of a Batch2 Job Instance.
StepExecutionDetails<PT extends ca.uhn.fhir.model.api.IModelJson,IT extends ca.uhn.fhir.model.api.IModelJson> - Class in ca.uhn.fhir.batch2.api
StepExecutionDetails(PT, IT, JobInstance, WorkChunk) - Constructor for class ca.uhn.fhir.batch2.api.StepExecutionDetails
StepExecutionDetails(PT, IT, JobInstance, String) - Constructor for class ca.uhn.fhir.batch2.api.StepExecutionDetails: Deprecated.
StepExecutor - Class in ca.uhn.fhir.batch2.coordinator
StepExecutor(IJobPersistence) - Constructor for class ca.uhn.fhir.batch2.coordinator.StepExecutor
stop() - Method in class ca.uhn.fhir.batch2.coordinator.JobCoordinatorImpl
storeNewInstance(JobInstance) - Method in interface ca.uhn.fhir.batch2.api.IJobPersistence: Store a new job instance.
SUCCESS - Enum constant in enum ca.uhn.fhir.batch2.model.ChunkOutcome.Status
SUCCESS - Static variable in class ca.uhn.fhir.batch2.api.RunOutcome: RunOutcome with 0 records processed
SUCCESS() - Static method in class ca.uhn.fhir.batch2.model.ChunkOutcome

T

targetStepId - Variable in class ca.uhn.fhir.batch2.model.WorkChunkCreateEvent
toString() - Method in class ca.uhn.fhir.batch2.api.IJobPersistence.CreateResult
toString() - Method in class ca.uhn.fhir.batch2.jobs.chunk.ResourceIdListWorkChunkJson
toString() - Method in class ca.uhn.fhir.batch2.jobs.chunk.TypedPidJson
toString() - Method in class ca.uhn.fhir.batch2.jobs.parameters.PartitionedUrl
toString() - Method in class ca.uhn.fhir.batch2.model.JobInstance
toString() - Method in class ca.uhn.fhir.batch2.model.JobInstanceStartRequest
toString() - Method in class ca.uhn.fhir.batch2.model.JobWorkNotification
toString() - Method in class ca.uhn.fhir.batch2.model.WorkChunk
toString() - Method in class ca.uhn.fhir.batch2.progress.InstanceProgress
toWorkChunk() - Method in class ca.uhn.fhir.batch2.model.WorkChunkMetadata
triggerMaintenancePass() - Method in interface ca.uhn.fhir.batch2.api.IJobMaintenanceService: Do not wait for the next scheduled time for maintenance.
triggerMaintenancePass() - Method in class ca.uhn.fhir.batch2.maintenance.JobMaintenanceServiceImpl
triggerReductionStep(String, JobWorkCursor<?, ?, ?>) - Method in interface ca.uhn.fhir.batch2.api.IReductionStepExecutorService
triggerReductionStep(String, JobWorkCursor<?, ?, ?>) - Method in class ca.uhn.fhir.batch2.coordinator.ReductionStepExecutorServiceImpl
TypedPidJson - Class in ca.uhn.fhir.batch2.jobs.chunk
TypedPidJson() - Constructor for class ca.uhn.fhir.batch2.jobs.chunk.TypedPidJson
TypedPidJson(TypedResourcePid) - Constructor for class ca.uhn.fhir.batch2.jobs.chunk.TypedPidJson
TypedPidJson(String, String) - Constructor for class ca.uhn.fhir.batch2.jobs.chunk.TypedPidJson

U

updateInstance(JobInstance) - Method in class ca.uhn.fhir.batch2.progress.InstanceProgress
updateInstance(JobInstance, boolean) - Method in class ca.uhn.fhir.batch2.progress.InstanceProgress: Update the job instance with status information.
updateInstance(String, IJobPersistence.JobInstanceUpdateCallback) - Method in interface ca.uhn.fhir.batch2.api.IJobPersistence: Brute-force hack for now to create a tx boundary - takes a write-lock on the instance while the theModifier runs.
updateInstanceForReductionStep(JobInstance) - Method in class ca.uhn.fhir.batch2.progress.InstanceProgress: Signal to the progress calculator to skip the incomplete work chunk count when determining the completed percentage.
updateInstanceStatus(JobInstance, StatusEnum) - Method in class ca.uhn.fhir.batch2.progress.JobInstanceStatusUpdater: Update the status on the instance, and call any completion handlers when entering a completion state.
updateInstanceUpdateTime(String) - Method in interface ca.uhn.fhir.batch2.api.IJobPersistence
updatePollWaitingChunksForJobIfReady(String) - Method in interface ca.uhn.fhir.batch2.api.IJobPersistence: Updates all Work Chunks in POLL_WAITING if their nextPollTime <= now for the given Job Instance.
UrlListValidator - Class in ca.uhn.fhir.batch2.jobs.parameters
UrlListValidator(String, IBatch2DaoSvc) - Constructor for class ca.uhn.fhir.batch2.jobs.parameters.UrlListValidator
UrlPartitioner - Class in ca.uhn.fhir.batch2.jobs.parameters
UrlPartitioner(MatchUrlService, IRequestPartitionHelperSvc) - Constructor for class ca.uhn.fhir.batch2.jobs.parameters.UrlPartitioner

V

validate(RequestDetails, T) - Method in interface ca.uhn.fhir.batch2.api.IJobParametersValidator: Validate the given job parameters.
validateUrls(List<String>) - Method in interface ca.uhn.fhir.batch2.jobs.parameters.IUrlListValidator
validateUrls(List<String>) - Method in class ca.uhn.fhir.batch2.jobs.parameters.UrlListValidator
valueOf(String) - Static method in enum ca.uhn.fhir.batch2.model.ChunkOutcome.Status: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum ca.uhn.fhir.batch2.model.StatusEnum: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum ca.uhn.fhir.batch2.model.WorkChunkStatusEnum: Returns the enum constant of this type with the specified name.
values() - Static method in enum ca.uhn.fhir.batch2.model.ChunkOutcome.Status: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum ca.uhn.fhir.batch2.model.StatusEnum: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum ca.uhn.fhir.batch2.model.WorkChunkStatusEnum: Returns an array containing the constants of this enum type, in the order they are declared.
VoidModel - Class in ca.uhn.fhir.batch2.api: Used as the input type for the first step
VoidModel() - Constructor for class ca.uhn.fhir.batch2.api.VoidModel

W

WorkChunk - Class in ca.uhn.fhir.batch2.model: Payload for step processing.
WorkChunk() - Constructor for class ca.uhn.fhir.batch2.model.WorkChunk: Constructor
WorkChunkCompletionEvent - Class in ca.uhn.fhir.batch2.model: Payload for the work-chunk completion event with the record and error counts.
WorkChunkCompletionEvent(String, int, int) - Constructor for class ca.uhn.fhir.batch2.model.WorkChunkCompletionEvent
WorkChunkCompletionEvent(String, int, int, String) - Constructor for class ca.uhn.fhir.batch2.model.WorkChunkCompletionEvent
WorkChunkCreateEvent - Class in ca.uhn.fhir.batch2.model: The data required for the create transition.
WorkChunkCreateEvent(String, int, String, String, int, String, boolean) - Constructor for class ca.uhn.fhir.batch2.model.WorkChunkCreateEvent: Constructor
WorkChunkData<OT extends ca.uhn.fhir.model.api.IModelJson> - Class in ca.uhn.fhir.batch2.model
WorkChunkData(OT) - Constructor for class ca.uhn.fhir.batch2.model.WorkChunkData: Constructor
WorkChunkErrorEvent - Class in ca.uhn.fhir.batch2.model: Payload for the work-chunk error event including the error message, and the allowed retry count.
WorkChunkErrorEvent(String) - Constructor for class ca.uhn.fhir.batch2.model.WorkChunkErrorEvent
WorkChunkErrorEvent(String, String) - Constructor for class ca.uhn.fhir.batch2.model.WorkChunkErrorEvent
workChunkId - Variable in class ca.uhn.fhir.batch2.api.IJobPersistence.CreateResult
WorkChunkMetadata - Class in ca.uhn.fhir.batch2.model
WorkChunkMetadata() - Constructor for class ca.uhn.fhir.batch2.model.WorkChunkMetadata
WorkChunkProcessor - Class in ca.uhn.fhir.batch2.coordinator
WorkChunkProcessor(IJobPersistence, BatchJobSender, IHapiTransactionService) - Constructor for class ca.uhn.fhir.batch2.coordinator.WorkChunkProcessor
WorkChunkStatusEnum - Enum in ca.uhn.fhir.batch2.model: States for the WorkChunk state machine.

A B C D E F G H I J L M N O P Q R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form