Package ca.uhn.fhir.jpa.bulk.export.job

Class BaseBulkItemReader

java.lang.Object

ca.uhn.fhir.jpa.bulk.export.job.BaseBulkItemReader

All Implemented Interfaces:

org.springframework.batch.item.ItemReader<List<ca.uhn.fhir.rest.api.server.storage.ResourcePersistentId>>

public abstract class BaseBulkItemReader
extends Object
implements org.springframework.batch.item.ItemReader<List<ca.uhn.fhir.rest.api.server.storage.ResourcePersistentId>>

Field Summary

Fields

Modifier and Type	Field	Description
protected ca.uhn.fhir.context.FhirContext	myContext
protected Long	myReadChunkSize
protected String	myResourceType

Constructor Summary

Constructors

Constructor	Description
BaseBulkItemReader()

Method Summary

Modifier and Type	Method	Description
SearchParameterMap	buildSearchParameterMapForTypeFilter(String theFilter, ca.uhn.fhir.context.RuntimeResourceDefinition theDef)
protected List<SearchParameterMap>	createSearchParameterMapsForResourceType()
protected abstract String	getLogInfoForRead()
protected ca.uhn.fhir.context.RuntimeResourceDefinition	getResourceDefinition()
protected abstract Iterator<ca.uhn.fhir.rest.api.server.storage.ResourcePersistentId>	getResourcePidIterator()
protected abstract Date	getSinceDate()
protected abstract String[]	getTypeFilterList()
protected void	loadResourcePIDs()	Generate the list of PIDs of all resources of the given myResourceType, which reference any group member of the given myGroupId.
List<ca.uhn.fhir.rest.api.server.storage.ResourcePersistentId>	read()

Methods inherited from class java.lang.Object

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

Field Details

myResourceType

@Value("#{stepExecutionContext[\'resourceType\']}")
protected String myResourceType

myReadChunkSize

@Value("#{jobParameters[\'readChunkSize\']}")
protected Long myReadChunkSize

myContext

@Autowired
protected ca.uhn.fhir.context.FhirContext myContext

Constructor Details

BaseBulkItemReader

public BaseBulkItemReader()

Method Details

loadResourcePIDs

protected void loadResourcePIDs()

Generate the list of PIDs of all resources of the given myResourceType, which reference any group member of the given myGroupId. Store them in a member iterator.

getResourcePidIterator

protected abstract Iterator<ca.uhn.fhir.rest.api.server.storage.ResourcePersistentId> getResourcePidIterator()

getTypeFilterList

protected abstract String[] getTypeFilterList()

getSinceDate

protected abstract Date getSinceDate()

getLogInfoForRead

protected abstract String getLogInfoForRead()

createSearchParameterMapsForResourceType

protected List<SearchParameterMap> createSearchParameterMapsForResourceType()

buildSearchParameterMapForTypeFilter

public SearchParameterMap buildSearchParameterMapForTypeFilter(String theFilter,
 ca.uhn.fhir.context.RuntimeResourceDefinition theDef)

getResourceDefinition

protected ca.uhn.fhir.context.RuntimeResourceDefinition getResourceDefinition()

read

public List<ca.uhn.fhir.rest.api.server.storage.ResourcePersistentId> read()

Specified by:

read in interface org.springframework.batch.item.ItemReader<List<ca.uhn.fhir.rest.api.server.storage.ResourcePersistentId>>