Package com.ibm.fhir.bulkdata.jbatch.export.patient

Class ChunkReader

java.lang.Object

javax.batch.api.chunk.AbstractItemReader

com.ibm.fhir.bulkdata.jbatch.export.patient.ChunkReader

All Implemented Interfaces:

javax.batch.api.chunk.ItemReader

Direct Known Subclasses:

ChunkReader

@Dependent
public class ChunkReader
extends javax.batch.api.chunk.AbstractItemReader

Bulk Export for Patient - ChunkReader. Processes a Page of Patients at a Time Per Read

Field Summary

Fields

Modifier and Type	Field	Description
protected BulkDataContext	ctx
(package private) boolean	isDoDuplicationCheck
(package private) javax.batch.runtime.context.JobContext	jobCtx
(package private) Set<String>	loadedPatientIds
protected int	pageNum
protected int	pageSize
protected Class<? extends Resource>	resourceType
protected 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

Modifier and Type	Method	Description
Serializable	checkpointInfo()
void	close()
protected FHIRPersistence	getPersistence()	gets the persistence object
void	open(Serializable checkpoint)
Object	readItem()

Methods inherited from class java.lang.Object

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

Field Detail

pageNum

protected int pageNum

pageSize

protected int pageSize

resourceType

protected Class<? extends Resource> resourceType

searchParametersForResoureTypes

protected Map<Class<? extends Resource>,List<Map<String,List<String>>>> searchParametersForResoureTypes

ctx

protected BulkDataContext ctx

isDoDuplicationCheck

boolean isDoDuplicationCheck

loadedPatientIds

Set<String> loadedPatientIds

stepCtx

@Inject
javax.batch.runtime.context.StepContext stepCtx

jobCtx

@Inject
javax.batch.runtime.context.JobContext jobCtx

Constructor Detail

ChunkReader

public ChunkReader()

Method Detail

open

public void open(Serializable checkpoint)
          throws Exception

Specified by:

open in interface javax.batch.api.chunk.ItemReader

Overrides:

open in class javax.batch.api.chunk.AbstractItemReader

Throws:

Exception

close

public void close()
           throws Exception

Specified by:

close in interface javax.batch.api.chunk.ItemReader

Overrides:

close in class javax.batch.api.chunk.AbstractItemReader

Throws:

Exception

checkpointInfo

public Serializable checkpointInfo()
                            throws Exception

Specified by:

checkpointInfo in interface javax.batch.api.chunk.ItemReader

Overrides:

checkpointInfo in class javax.batch.api.chunk.AbstractItemReader

Throws:

Exception

readItem

public Object readItem()
                throws Exception

Specified by:

readItem in interface javax.batch.api.chunk.ItemReader

Specified by:

readItem in class javax.batch.api.chunk.AbstractItemReader

Throws:

Exception

getPersistence

protected FHIRPersistence getPersistence()

gets the persistence object

Returns: