Package kieker.extension.cassandra.reader

Class CassandraDb

java.lang.Object
kieker.extension.cassandra.reader.CassandraDb
public class CassandraDb
extends java.lang.Object
Author:
Armin Moebius, Sven Ulrich

  • Constructor Summary

    Constructors 
    Constructor Description
    CassandraDb​(java.lang.String keyspace, java.util.List<java.net.InetSocketAddress> contactPoints)
    Creates a new instance of this class using the given parameter.

  • Method Summary

    Modifier and Type Method Description
    void connect()
    Establishes a connection to the database.
    void disconnect()
    Closes all open sessions and connections to the database.
    com.datastax.oss.driver.api.core.cql.ResultSet select​(java.util.List<java.lang.String> fields, java.lang.String table, java.lang.String whereClause)
    Select data form the Cassandra cluster.

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • CassandraDb

      public CassandraDb​(java.lang.String keyspace, java.util.List<java.net.InetSocketAddress> contactPoints)
      Creates a new instance of this class using the given parameter.
      Parameters:
      keyspace -
      contactPoints -

  • Method Details

    • connect

      public void connect()
      Establishes a connection to the database.

    • disconnect

      public void disconnect()
      Closes all open sessions and connections to the database.

    • select

      public com.datastax.oss.driver.api.core.cql.ResultSet select​(java.util.List<java.lang.String> fields, java.lang.String table, java.lang.String whereClause)
      Select data form the Cassandra cluster.
      Parameters:
      fields -
      table -
      whereClause -
      Returns:
      returns a result set