Class ChunkReader
- java.lang.Object
-
- javax.batch.api.chunk.AbstractItemReader
-
- com.ibm.fhir.jbatch.bulkdata.export.system.ChunkReader
-
- All Implemented Interfaces:
javax.batch.api.chunk.ItemReader
@Dependent public class ChunkReader extends javax.batch.api.chunk.AbstractItemReader
Bulk system export Chunk implementation - the Reader.
-
-
Field Summary
Fields Modifier and Type Field Description (package private) String
fhirDatastoreId
Fhir data store id.protected String
fhirExportFormat
Fhir export format.(package private) FHIRPersistence
fhirPersistence
(package private) String
fhirResourceType
Fhir resource type to process.(package private) String
fhirSearchFromDate
Fhir Search from date.(package private) String
fhirSearchPageSize
Fhir search page size.(package private) String
fhirSearchToDate
Fhir search to date.(package private) String
fhirTenant
Fhir tenant id.(package private) String
fhirTypeFilters
Fhir export type filters.(package private) String
incomingUrl
(package private) int
indexOfCurrentTypeFilter
(package private) boolean
isDoDuplicationCheck
(package private) boolean
isSingleCosObject
(package private) Set<String>
loadedResourceIds
(package private) int
pageNum
(package private) int
pageSize
(package private) Class<? extends Resource>
resourceType
(package private) Map<Class<? extends Resource>,List<Map<String,List<String>>>>
searchParametersForResoureTypes
(package private) javax.batch.runtime.context.StepContext
stepCtx
-
Constructor Summary
Constructors Constructor Description ChunkReader()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Serializable
checkpointInfo()
void
close()
void
open(Serializable checkpoint)
Object
readItem()
-
-
-
Field Detail
-
isSingleCosObject
boolean isSingleCosObject
-
pageNum
int pageNum
-
pageSize
int pageSize
-
searchParametersForResoureTypes
Map<Class<? extends Resource>,List<Map<String,List<String>>>> searchParametersForResoureTypes
-
indexOfCurrentTypeFilter
int indexOfCurrentTypeFilter
-
isDoDuplicationCheck
boolean isDoDuplicationCheck
-
fhirPersistence
FHIRPersistence fhirPersistence
-
fhirTenant
@Inject String fhirTenant
Fhir tenant id.
-
fhirDatastoreId
@Inject String fhirDatastoreId
Fhir data store id.
-
fhirResourceType
@Inject String fhirResourceType
Fhir resource type to process.
-
fhirExportFormat
@Inject protected String fhirExportFormat
Fhir export format.
-
fhirSearchFromDate
@Inject String fhirSearchFromDate
Fhir Search from date.
-
fhirSearchToDate
@Inject String fhirSearchToDate
Fhir search to date.
-
fhirTypeFilters
@Inject String fhirTypeFilters
Fhir export type filters.
-
fhirSearchPageSize
@Inject String fhirSearchPageSize
Fhir search page size.
-
incomingUrl
@Inject String incomingUrl
-
stepCtx
@Inject javax.batch.runtime.context.StepContext stepCtx
-
-
Method Detail
-
readItem
public Object readItem() throws Exception
- Specified by:
readItem
in interfacejavax.batch.api.chunk.ItemReader
- Specified by:
readItem
in classjavax.batch.api.chunk.AbstractItemReader
- Throws:
Exception
-
open
public void open(Serializable checkpoint) throws Exception
- Specified by:
open
in interfacejavax.batch.api.chunk.ItemReader
- Overrides:
open
in classjavax.batch.api.chunk.AbstractItemReader
- Throws:
Exception
-
close
public void close() throws Exception
- Specified by:
close
in interfacejavax.batch.api.chunk.ItemReader
- Overrides:
close
in classjavax.batch.api.chunk.AbstractItemReader
- Throws:
Exception
-
checkpointInfo
public Serializable checkpointInfo() throws Exception
- Specified by:
checkpointInfo
in interfacejavax.batch.api.chunk.ItemReader
- Overrides:
checkpointInfo
in classjavax.batch.api.chunk.AbstractItemReader
- Throws:
Exception
-
-