Package org.linuxforhealth.fhir.bulkdata.jbatch.export.patient

Class ChunkReader

java.lang.Object

javax.batch.api.chunk.AbstractItemReader

org.linuxforhealth.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) java.util.Set<java.lang.String>	loadedPatientIds
protected int	pageNum
protected int	pageSize
protected java.lang.Class<? extends Resource>	resourceType
protected java.util.Map<java.lang.Class<? extends Resource>,java.util.List<java.util.Map<java.lang.String,java.util.List<java.lang.String>>>>	searchParametersForResoureTypes
(package private) javax.batch.runtime.context.StepContext	stepCtx

Constructor Summary

Constructors

Constructor	Description
ChunkReader()

Method Summary

Modifier and Type	Method	Description
java.io.Serializable	checkpointInfo()
void	close()
protected FHIRPersistence	getPersistence()	gets the persistence object
void	open(java.io.Serializable checkpoint)
java.lang.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 java.lang.Class<? extends Resource> resourceType

searchParametersForResoureTypes

protected java.util.Map<java.lang.Class<? extends Resource>,java.util.List<java.util.Map<java.lang.String,java.util.List<java.lang.String>>>> searchParametersForResoureTypes

ctx

protected BulkDataContext ctx

isDoDuplicationCheck

boolean isDoDuplicationCheck

loadedPatientIds

java.util.Set<java.lang.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(java.io.Serializable checkpoint)
          throws java.lang.Exception

Specified by:

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

Overrides:

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

Throws:

java.lang.Exception

close

public void close()
           throws java.lang.Exception

Specified by:

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

Overrides:

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

Throws:

java.lang.Exception

checkpointInfo

public java.io.Serializable checkpointInfo()
                                    throws java.lang.Exception

Specified by:

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

Overrides:

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

Throws:

java.lang.Exception

readItem

public java.lang.Object readItem()
                          throws java.lang.Exception

Specified by:

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

Specified by:

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

Throws:

java.lang.Exception

getPersistence

protected FHIRPersistence getPersistence()

gets the persistence object

Returns: