suspend fun CassandraClient.connectAwait(): Unitsuspend fun CassandraClient.connectAwait(keyspace: String): Unit
Connect to a Cassandra service. |
|
suspend fun CassandraClient.disconnectAwait(): Unit
Disconnects from the Cassandra service. |
|
suspend fun CassandraClient.executeAwait(query: String): ResultSet
Execute the query and provide a handler for consuming results. suspend fun CassandraClient.executeAwait(statement: Statement): ResultSet
Execute the statement and provide a handler for consuming results. |
|
suspend fun CassandraClient.executeWithFullFetchAwait(query: String): List<Row>suspend fun CassandraClient.executeWithFullFetchAwait(statement: Statement): List<Row>
Execute the query and provide a handler for consuming results. |
|
suspend fun CassandraClient.prepareAwait(query: String): PreparedStatement
Prepares the provided query string. |
|
suspend fun CassandraClient.queryStreamAwait(sql: String): CassandraRowStream
Executes the given SQL SELECT statement which returns the results of the query as a read stream. suspend fun CassandraClient.queryStreamAwait(statement: Statement): CassandraRowStream
Executes the given SQL statement which returns the results of the query as a read stream. |