Package org.linuxforhealth.fhir.persistence.cassandra.payload

Class CqlStorePayload

java.lang.Object

org.linuxforhealth.fhir.persistence.cassandra.payload.CqlStorePayload

public class CqlStorePayload
extends java.lang.Object

DAO to store the resource record and payload data chunks

Constructor Summary

Constructors

Constructor	Description
CqlStorePayload(int resourceTypeId, java.lang.String logicalId, int version, java.lang.String resourcePayloadKey, InputOutputByteStream payloadStream)	Public constructor

Method Summary

Modifier and Type	Method	Description
void	run(com.datastax.oss.driver.api.core.CqlSession session)	Store the resource into the Cassandra database.

Methods inherited from class java.lang.Object

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

Constructor Detail

CqlStorePayload

public CqlStorePayload(int resourceTypeId,
                       java.lang.String logicalId,
                       int version,
                       java.lang.String resourcePayloadKey,
                       InputOutputByteStream payloadStream)

Public constructor

Parameters:

resourceTypeId -

logicalId -

version -

resourcePayloadKey -

payloadStream -

Method Detail

run

public void run(com.datastax.oss.driver.api.core.CqlSession session)
         throws FHIRPersistenceException

Store the resource into the Cassandra database. We rely on other services to ensure consistency during our writes (which are not isolated/atomic). This is why every object is given a UUID which we can use to check that the records we read are all associated with the same update

Parameters:

session -

Throws:

FHIRPersistenceException