| Package | Description | 
|---|---|
| io.vertx.rxjava.cassandra | 
| Modifier and Type | Field and Description | 
|---|---|
static io.vertx.lang.rx.TypeArg<CassandraClient> | 
CassandraClient.__TYPE_ARG  | 
| Modifier and Type | Method and Description | 
|---|---|
CassandraClient | 
CassandraClient.close()
Closes this client. 
 | 
CassandraClient | 
CassandraClient.close(Handler<AsyncResult<Void>> closeHandler)
Closes this client. 
 | 
static CassandraClient | 
CassandraClient.create(Vertx vertx)
Like  
create(io.vertx.rxjava.core.Vertx) with default options. | 
static CassandraClient | 
CassandraClient.create(Vertx vertx,
      CassandraClientOptions options)
Create a Cassandra client which maintains its own driver session. 
 | 
static CassandraClient | 
CassandraClient.createNonShared(Vertx vertx)
Deprecated.  
 | 
static CassandraClient | 
CassandraClient.createNonShared(Vertx vertx,
               CassandraClientOptions options)
Deprecated.  
 | 
static CassandraClient | 
CassandraClient.createShared(Vertx vertx)
Like  
createShared(io.vertx.rxjava.core.Vertx) with default options and client name. | 
static CassandraClient | 
CassandraClient.createShared(Vertx vertx,
            CassandraClientOptions options)
Like  
createShared(io.vertx.rxjava.core.Vertx) with default client name. | 
static CassandraClient | 
CassandraClient.createShared(Vertx vertx,
            String clientName)
Like  
createShared(io.vertx.rxjava.core.Vertx) with default options. | 
static CassandraClient | 
CassandraClient.createShared(Vertx vertx,
            String clientName,
            CassandraClientOptions options)
Create a Cassandra client that shares its driver session with any other client having the same name. 
 | 
CassandraClient | 
CassandraClient.execute(com.datastax.driver.core.Statement statement,
       Handler<AsyncResult<ResultSet>> resultHandler)
Execute the statement and provide a handler for consuming results. 
 | 
CassandraClient | 
CassandraClient.execute(String query,
       Handler<AsyncResult<ResultSet>> resultHandler)
Execute the query and provide a handler for consuming results. 
 | 
CassandraClient | 
CassandraClient.executeWithFullFetch(com.datastax.driver.core.Statement statement,
                    Handler<AsyncResult<List<com.datastax.driver.core.Row>>> resultHandler)
Execute the query and provide a handler for consuming results. 
 | 
CassandraClient | 
CassandraClient.executeWithFullFetch(String query,
                    Handler<AsyncResult<List<com.datastax.driver.core.Row>>> resultHandler)
Execute the query and provide a handler for consuming results. 
 | 
static CassandraClient | 
CassandraClient.newInstance(CassandraClient arg)  | 
CassandraClient | 
CassandraClient.prepare(String query,
       Handler<AsyncResult<com.datastax.driver.core.PreparedStatement>> resultHandler)
Prepares the provided query string. 
 | 
CassandraClient | 
CassandraClient.queryStream(com.datastax.driver.core.Statement statement,
           Handler<AsyncResult<CassandraRowStream>> rowStreamHandler)
Executes the given SQL statement which returns the results of the query as a read stream. 
 | 
CassandraClient | 
CassandraClient.queryStream(String sql,
           Handler<AsyncResult<CassandraRowStream>> rowStreamHandler)
Executes the given SQL  
SELECT statement which returns the results of the query as a read stream. | 
| Modifier and Type | Method and Description | 
|---|---|
static MappingManager | 
MappingManager.create(CassandraClient client)
Create a  
MappingManager from the given CassandraClient. | 
Copyright © 2020 Eclipse. All rights reserved.