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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
run(com.datastax.oss.driver.api.core.CqlSession session)
Store the resource into the Cassandra database.
-
-
-
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
-
-