Interface CassandraSession


  • public interface CassandraSession
    A thin facade on top of Cassandra's session. The purpose of using this interface rather than Cassandra's Session directly is because Newts wraps the session in a similar interface and does not expose the session directly. So rather than depending on the newts version of the interface in OpenNMS we have this one and proxy between them in NewtsCassandraSessionFactory. The implication being that any future implementations that may expose a Session directly will have to wrap it with this interface, but that should be trivial.
    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      com.datastax.driver.core.ResultSet execute​(com.datastax.driver.core.Statement statement)  
      com.datastax.driver.core.ResultSet execute​(java.lang.String statement)  
      com.datastax.driver.core.ResultSetFuture executeAsync​(com.datastax.driver.core.Statement statement)  
      com.datastax.driver.core.PreparedStatement prepare​(com.datastax.driver.core.RegularStatement statement)  
      com.datastax.driver.core.PreparedStatement prepare​(java.lang.String statement)  
      java.util.concurrent.Future<java.lang.Void> shutdown()  
    • Method Detail

      • prepare

        com.datastax.driver.core.PreparedStatement prepare​(java.lang.String statement)
      • prepare

        com.datastax.driver.core.PreparedStatement prepare​(com.datastax.driver.core.RegularStatement statement)
      • executeAsync

        com.datastax.driver.core.ResultSetFuture executeAsync​(com.datastax.driver.core.Statement statement)
      • execute

        com.datastax.driver.core.ResultSet execute​(com.datastax.driver.core.Statement statement)
      • execute

        com.datastax.driver.core.ResultSet execute​(java.lang.String statement)
      • shutdown

        java.util.concurrent.Future<java.lang.Void> shutdown()