Dependencies
- avalon-framework/avalon-framework/4.1.5 (available as org.apache.avalon.framework/avalon-framework-impl/4.3.1)
- com.datastax.cassandra/cassandra-driver-core/3.5.0 (available as com.datastax.oss/java-driver-core/4.3.0)
- com.datastax.cassandra/cassandra-driver-mapping/3.5.0
- com.fasterxml.jackson.core/jackson-annotations/2.9.0
- com.fasterxml.jackson.core/jackson-core/2.9.9
- com.fasterxml.jackson.core/jackson-databind/2.9.9.1
- com.github.jnr/jffi/1.2.16
- com.github.jnr/jffi/1.2.16/native
- com.github.jnr/jnr-constants/0.9.9
- com.github.jnr/jnr-ffi/2.1.7
- com.github.jnr/jnr-posix/3.0.44
- com.github.jnr/jnr-x86asm/1.0.2
- com.google.code.findbugs/jsr305/1.3.9
- com.google.errorprone/error_prone_annotations/2.0.12
- com.google.guava/guava/20.0
- com.google.j2objc/j2objc-annotations/1.1
- com.google.protobuf/protobuf-java/2.5.0
- com.jcraft/jzlib/1.1.3
- commons-logging/commons-logging/1.2
- com.sun/tools/1.8
- io.dropwizard.metrics/metrics-core/3.2.2
- io.netty/netty-buffer/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec/4.0.56.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-dns/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-http2/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-http/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-socks/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-common/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-handler/4.0.56.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-handler-proxy/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-resolver/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-resolver-dns/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-epoll/4.0.56.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-kqueue/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-unix-common/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.vertx/vertx-codegen/3.8.0
- io.vertx/vertx-core/3.8.0
- io.vertx/vertx-docgen/0.9.2
- java/11
- jdk/srczip/999
- log4j/log4j/1.2.17
- logkit/logkit/1.0.1
- org.apache.geronimo.specs/geronimo-jms_1.1_spec/1.0
- org.apache.logging.log4j/log4j-api/2.6.2
- org.bouncycastle/bcpkix-jdk15on/1.50
- org.bouncycastle/bcprov-jdk15on/1.50
- org.codehaus.mojo/animal-sniffer-annotations/1.14
- org.conscrypt/conscrypt-openjdk-uber/1.0.0.RC13
- org.hdrhistogram/HdrHistogram/2.1.10
- org.jboss.marshalling/jboss-marshalling/1.4.11.Final
- org.lz4/lz4-java/1.4.1
- org.mvel/mvel2/2.3.1.Final
- org.ow2.asm/asm/5.0.3
- org.ow2.asm/asm-analysis/5.0.3
- org.ow2.asm/asm-commons/5.0.3
- org.ow2.asm/asm-tree/5.0.3
- org.ow2.asm/asm-util/5.0.3
- org.slf4j/slf4j-api/1.7.21
- org.xerial.snappy/snappy-java/1.1.2.6
Declarations
-
examples
-
CassandraClientExamples
- specifyingNodes(Vertx): void
- portAndKeyspace(Vertx): void
- sharedClient(Vertx): void
- lowLevelQuerying(CassandraClient): void
- executeAndCollect(CassandraClient): void
- streamingViaHttp(Vertx, CassandraClient, HttpServerResponse): void
- fetchAll(CassandraClient): void
- prepareQuery(CassandraClient): void
- usingPreparedStatementFuture(CassandraClient, PreparedStatement): void
- batching(CassandraClient): void
- MappedClass
- objectMapper(CassandraClient): void
-
CassandraClientExamples
-
io
-
vertx
-
cassandra
-
CassandraClient
- DEFAULT_SHARED_CLIENT_NAME: String
- createNonShared(Vertx): CassandraClient
- createNonShared(Vertx, CassandraClientOptions): CassandraClient
- createShared(Vertx): CassandraClient
- createShared(Vertx, String): CassandraClient
- createShared(Vertx, CassandraClientOptions): CassandraClient
- createShared(Vertx, String, CassandraClientOptions): CassandraClient
- isConnected(): boolean
- executeWithFullFetch(String, Handler<AsyncResult<List<Row>>>): CassandraClient
- executeWithFullFetch(Statement, Handler<AsyncResult<List<Row>>>): CassandraClient
- execute(String, Handler<AsyncResult<ResultSet>>): CassandraClient
- execute(String, Collector<Row, Object, Object>, Handler<AsyncResult<Object>>): CassandraClient
- execute(Statement, Handler<AsyncResult<ResultSet>>): CassandraClient
- execute(Statement, Collector<Row, Object, Object>, Handler<AsyncResult<Object>>): CassandraClient
- prepare(String, Handler<AsyncResult<PreparedStatement>>): CassandraClient
- queryStream(String, Handler<AsyncResult<CassandraRowStream>>): CassandraClient
- queryStream(Statement, Handler<AsyncResult<CassandraRowStream>>): CassandraClient
- close(): CassandraClient
- close(Handler<AsyncResult<Void>>): CassandraClient
-
CassandraClientOptions
- CassandraClientOptions(): void
- DEFAULT_PORT: int
- DEFAULT_HOST: String
- builder: Builder
- keyspace: String
- CassandraClientOptions(CassandraClientOptions): void
- CassandraClientOptions(Builder): void
- CassandraClientOptions(JsonObject): void
- toJson(): JsonObject
- setContactPoints(List<String>): CassandraClientOptions
- setPort(int): CassandraClientOptions
- addContactPoint(String): CassandraClientOptions
- getContactPoints(): List<String>
- dataStaxClusterBuilder(): Builder
- getKeyspace(): String
- setKeyspace(String): CassandraClientOptions
- CassandraClientOptionsConverter
- CassandraRowStream
- Mapper
- MappingManager
-
ResultSet
- isExhausted(): boolean
- isFullyFetched(): boolean
- getAvailableWithoutFetching(): int
- fetchMoreResults(Handler<AsyncResult<Void>>): ResultSet
- one(Handler<AsyncResult<Row>>): ResultSet
- several(int, Handler<AsyncResult<List<Row>>>): ResultSet
- all(Handler<AsyncResult<List<Row>>>): ResultSet
- getColumnDefinitions(): ColumnDefinitions
- wasApplied(): boolean
-
impl
-
CassandraClientImpl
- HOLDERS_LOCAL_MAP_NAME: String
- vertx: VertxInternal
- clientName: String
- options: CassandraClientOptions
- holders: Map<String, SessionHolder>
- connectionQueue: TaskQueue
- cachedSession: Session
- closed: boolean
- CassandraClientImpl(Vertx, String, CassandraClientOptions): void
- isConnected(): boolean
- executeWithFullFetch(String, Handler<AsyncResult<List<Row>>>): CassandraClient
- executeWithFullFetch(Statement, Handler<AsyncResult<List<Row>>>): CassandraClient
- execute(String, Handler<AsyncResult<ResultSet>>): CassandraClient
- execute(String, Collector<Row, Object, Object>, Handler<AsyncResult<Object>>): CassandraClient
- execute(Statement, Handler<AsyncResult<ResultSet>>): CassandraClient
- execute(Statement, Collector<Row, Object, Object>, Handler<AsyncResult<Object>>): CassandraClient
- executeAndCollect(Statement, Collector<Row, Object, Object>, Handler<AsyncResult<Object>>): void
- prepare(String, Handler<AsyncResult<PreparedStatement>>): CassandraClient
- queryStream(String, Handler<AsyncResult<CassandraRowStream>>): CassandraClient
- queryStream(Statement, Handler<AsyncResult<CassandraRowStream>>): CassandraClient
- close(): CassandraClient
- close(Handler<AsyncResult<Void>>): CassandraClient
- getSession(ContextInternal, Handler<AsyncResult<Session>>): void
- connect(Promise<Session>, Map<String, SessionHolder>, String, CassandraClientOptions): void
-
CassandraRowStreamImpl
- State
- context: Context
- resultSet: ResultSet
- internalQueue: InboundBuffer<Row>
- state: State
- inFlight: int
- handler: Handler<Row>
- exceptionHandler: Handler<Throwable>
- endHandler: Handler<Void>
- CassandraRowStreamImpl(Context, ResultSet): void
- exceptionHandler(Handler<Throwable>): CassandraRowStream
- handler(Handler<Row>): CassandraRowStream
- pause(): CassandraRowStream
- resume(): CassandraRowStream
- endHandler(Handler<Void>): CassandraRowStream
- fetch(long): CassandraRowStream
- fetchRow(): void
- handleFetched(Row): void
- handleRow(Row): void
- handleException(Throwable): void
- handleEnd(): void
- stop(): void
-
MapperImpl
- mappingManager: MappingManagerImpl
- mappedClass: Class<Object>
- mapper: Mapper<Object>
- MapperImpl(MappingManagerImpl, Class<Object>): void
- save(Object, Handler<AsyncResult<Void>>): void
- delete(List<Object>, Handler<AsyncResult<Void>>): void
- get(List<Object>, Handler<AsyncResult<Object>>): void
- getMapper(ContextInternal, Handler<AsyncResult<Mapper>>): void
- MappingManagerImpl
-
ResultSetImpl
- resultSet: ResultSet
- vertx: Vertx
- ResultSetImpl(ResultSet, Vertx): void
- isExhausted(): boolean
- isFullyFetched(): boolean
- getAvailableWithoutFetching(): int
- fetchMoreResults(Handler<AsyncResult<Void>>): ResultSet
- one(Handler<AsyncResult<Row>>): ResultSet
- several(int, Handler<AsyncResult<List<Row>>>): ResultSet
- loadSeveral(int, List<Row>, Handler<AsyncResult<List<Row>>>): void
- getRows(int): List<Row>
- all(Handler<AsyncResult<List<Row>>>): ResultSet
- loadMore(Context, List<Row>, Handler<AsyncResult<List<Row>>>): void
- getColumnDefinitions(): ColumnDefinitions
- wasApplied(): boolean
- SessionHolder
- Util
-
CassandraClientImpl
-
CassandraClient
-
cassandra
-
vertx