Package kieker.extension.cassandra.reader

Class CassandraDb

java.lang.Object

kieker.extension.cassandra.reader.CassandraDb

public class CassandraDb
extends Object

Author:

Armin Moebius, Sven Ulrich

Constructor Summary

Constructors

Constructor	Description
CassandraDb(String keyspace, List<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(List<String> fields, String table, 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(String keyspace,
 List<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(List<String> fields,
 String table,
 String whereClause)

Select data form the Cassandra cluster.

Parameters:

fields -

table -

whereClause -

Returns:

returns a result set