Package com.ibm.fhir.bulkdata.jbatch.load

Class ChunkWriter

java.lang.Object

javax.batch.api.chunk.AbstractItemWriter

com.ibm.fhir.bulkdata.jbatch.load.ChunkWriter

All Implemented Interfaces:

javax.batch.api.chunk.ItemWriter

@Dependent
public class ChunkWriter
extends javax.batch.api.chunk.AbstractItemWriter

BulkData $import ChunkWriter

Field Summary

Fields

Modifier and Type	Field	Description
(package private) javax.batch.runtime.context.JobContext	jobCtx
(package private) javax.batch.runtime.context.StepContext	stepCtx

Constructor Summary

Constructors

Constructor	Description
ChunkWriter()

Method Summary

Modifier and Type	Method	Description
OperationOutcome	conditionalFingerprintUpdate(ImportTransientUserData chunkData, boolean skip, Map<String,SaltHash> localCache, FHIRPersistence persistence, FHIRPersistenceContext context, String logicalId, Resource resource)	conditional update checks to see if our cache contains the key, if not reads from the db, and calculates the cache.
void	open(Serializable checkpoint)
void	writeItems(List<Object> arg0)

Methods inherited from class javax.batch.api.chunk.AbstractItemWriter

checkpointInfo, close

Methods inherited from class java.lang.Object

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

Field Detail

stepCtx

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

jobCtx

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

Constructor Detail

ChunkWriter

public ChunkWriter()

Method Detail

open

public void open(Serializable checkpoint)
          throws Exception

Specified by:

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

Overrides:

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

Throws:

Exception

writeItems

public void writeItems(List<Object> arg0)
                throws Exception

Specified by:

writeItems in interface javax.batch.api.chunk.ItemWriter

Specified by:

writeItems in class javax.batch.api.chunk.AbstractItemWriter

Throws:

Exception

conditionalFingerprintUpdate

public OperationOutcome conditionalFingerprintUpdate(ImportTransientUserData chunkData,
                                                     boolean skip,
                                                     Map<String,SaltHash> localCache,
                                                     FHIRPersistence persistence,
                                                     FHIRPersistenceContext context,
                                                     String logicalId,
                                                     Resource resource)
                                              throws FHIRPersistenceException

conditional update checks to see if our cache contains the key, if not reads from the db, and calculates the cache. The cache is saved within the context of this particular execution, and then destroyed.

Parameters:

chunkData - the transient user data used increment the number of skips

skip - should skip the resource if it matches

localCache - map containing the key-saltHash

persistence - used to facilitate the calls to the underlying db

context - used in db calls

logicalId - the logical id of the FHIR resource (e.g. 1-2-3-4)

resource - the FHIR Resource

Returns:

outcomes including information or warnings

Throws:

FHIRPersistenceException