Class CqlSaveResource


  • public class CqlSaveResource
    extends java.lang.Object
    DAO command to save a resource payload object in Cassandra.
    • Constructor Summary

      Constructors 
      Constructor Description
      CqlSaveResource​(java.lang.String partitionId, java.lang.String logicalId, java.lang.String payloadId, int version, byte[] payload)
      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.
      • Methods inherited from class java.lang.Object

        clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • CqlSaveResource

        public CqlSaveResource​(java.lang.String partitionId,
                               java.lang.String logicalId,
                               java.lang.String payloadId,
                               int version,
                               byte[] payload)
        Public constructor
        Parameters:
        partitionId -
        logicalId -
        payloadId -
        version -
        payload -
    • Method Detail

      • run

        public void run​(com.datastax.oss.driver.api.core.CqlSession session)
        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 -