Dependencies
- ant/ant/1.6.2 (available as org.apache.ant/ant/1.10.7)
- avalon-framework/avalon-framework/4.1.5 (available as org.apache.avalon.framework/avalon-framework-impl/4.3.1)
- com.datastax.oss/java-driver-core/4.9.0
- com.datastax.oss/java-driver-mapper-runtime/4.9.0
- com.datastax.oss/java-driver-query-builder/4.9.0
- com.datastax.oss/java-driver-shaded-guava/25.1-jre-graal-sub-1
- com.datastax.oss/native-protocol/1.4.11
- com.esotericsoftware/kryo-shaded/3.0.3
- com.esotericsoftware/minlog/1.3.0
- com.esri.geometry/esri-geometry-api/1.2.1
- com.fasterxml.jackson.core/jackson-annotations/2.11.0
- com.fasterxml.jackson.core/jackson-core/2.11.0
- com.fasterxml.jackson.core/jackson-databind/2.11.0
- com.github.jnr/jffi/1.2.19
- com.github.jnr/jffi/1.2.19/native
- com.github.jnr/jnr-a64asm/1.0.0
- com.github.jnr/jnr-constants/0.9.12
- com.github.jnr/jnr-ffi/2.1.10
- com.github.jnr/jnr-posix/3.0.50
- com.github.jnr/jnr-x86asm/1.0.2
- com.github.jponge/lzma-java/1.3
- com.github.spotbugs/spotbugs-annotations/3.1.12
- com.github.stephenc.jcip/jcip-annotations/1.0-1
- com.google.code.findbugs/jsr305/3.0.2
- com.google.protobuf.nano/protobuf-javanano/3.0.0-alpha-5
- com.google.protobuf/protobuf-java/2.6.1
- com.jcraft/jsch/0.1.42
- com.jcraft/jzlib/1.1.3
- commons-beanutils/commons-beanutils/1.8.3
- commons-codec/commons-codec/1.6
- commons-collections/commons-collections/3.2.2
- commons-configuration/commons-configuration/1.10
- commons-digester/commons-digester/1.8.1
- commons-httpclient/commons-httpclient/3.1
- commons-jxpath/commons-jxpath/1.3
- commons-lang/commons-lang/2.6
- commons-logging/commons-logging/1.2
- commons-net/commons-net/2.2
- com.ning/compress-lzf/1.0.3
- com.squareup/javapoet/1.8.0
- com.sun/tools/1.8
- com.typesafe/config/1.3.4
- io.dropwizard.metrics/metrics-core/4.0.5
- io.netty/netty-buffer/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec/4.1.51.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-dns/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-haproxy/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-http2/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-http/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-socks/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-common/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-handler/4.1.51.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-handler-proxy/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-resolver/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-resolver-dns/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-tcnative/2.0.31.Final
- io.netty/netty-transport/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-epoll/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-kqueue/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-unix-common/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.projectreactor.tools/blockhound/1.0.3.RELEASE
- io.vertx/vertx-codegen/4.0.0
- io.vertx/vertx-core/4.0.0
- io.vertx/vertx-docgen/0.9.2
- java/11
- jaxen/jaxen/1.0-FCS
- jdom/jdom/1.0
- log4j/log4j/1.2.17
- logkit/logkit/1.0.1
- net.jpountz.lz4/lz4/1.3.0
- org.apache.commons/commons-jexl/2.1.1
- org.apache.commons/commons-lang3/3.8.1
- org.apache.commons/commons-vfs2/2.0
- org.apache.geronimo.specs/geronimo-jms_1.1_spec/1.0
- org.apache.jackrabbit/jackrabbit-jcr-commons/1.5.2
- org.apache.jackrabbit/jackrabbit-webdav/1.5.2
- org.apache.logging.log4j/log4j-api/2.6.2
- org.apache.maven.scm/maven-scm-api/1.4
- org.apache.maven.scm/maven-scm-provider-svn-commons/1.4
- org.apache.maven.scm/maven-scm-provider-svnexe/1.4
- org.apache.tinkerpop/gremlin-core/3.4.8
- org.apache.tinkerpop/gremlin-shaded/3.4.8
- org.apache.tinkerpop/tinkergraph-gremlin/3.4.8
- org.bouncycastle/bcpkix-jdk15on/1.65
- org.bouncycastle/bcprov-jdk15on/1.65
- org.codehaus.jackson/jackson-core-asl/1.9.12
- org.codehaus.plexus/plexus-utils/1.5.6
- org.conscrypt/conscrypt-openjdk-uber/2.4.0
- org.hdrhistogram/HdrHistogram/2.1.10
- org.javatuples/javatuples/1.2
- org.jboss.marshalling/jboss-marshalling/1.4.11.Final
- org.json/json/20090211
- org.lz4/lz4-java/1.6.0
- org.objenesis/objenesis/2.1
- org.ow2.asm/asm/7.1
- org.ow2.asm/asm-analysis/7.1
- org.ow2.asm/asm-commons/7.1
- org.ow2.asm/asm-tree/7.1
- org.ow2.asm/asm-util/7.1
- org.reactivestreams/reactive-streams/1.0.2
- org.slf4j/jcl-over-slf4j/1.7.25
- org.slf4j/slf4j-api/1.7.21
- org.xerial.snappy/snappy-java/1.1.7.3
- regexp/regexp/1.3
- saxpath/saxpath/1.0-FCS
- xalan/xalan/2.5.0
- xerces/xercesImpl/2.6.0
- xml-resolver/xml-resolver/1.2
Declarations
-
examples
-
CassandraClientExamples
- specifyingNodes(Vertx): void
- portAndKeyspace(Vertx): void
- sharedClient(Vertx): void
- lowLevelQuerying(CassandraClient): void
- executeAndCollect(CassandraClient, Collector<Row, Object, String>): void
- streamingViaHttp(Vertx, CassandraClient, HttpServerResponse): void
- fetchAll(CassandraClient): void
- prepareQuery(CassandraClient): void
- usingPreparedStatementFuture(CassandraClient, PreparedStatement): void
- batching(CassandraClient): void
-
CassandraClientExamples
-
io
-
vertx
-
cassandra
-
CassandraClient
- close(Handler<AsyncResult<Void>>): CassandraClient
- DEFAULT_SHARED_CLIENT_NAME: String
- create(Vertx): CassandraClient
- create(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(String): Future<List<Row>>
- executeWithFullFetch(Statement, Handler<AsyncResult<List<Row>>>): CassandraClient
- executeWithFullFetch(Statement): Future<List<Row>>
- execute(String, Handler<AsyncResult<ResultSet>>): CassandraClient
- execute(String): Future<ResultSet>
- execute(String, Collector<Row, Object, Object>, Handler<AsyncResult<Object>>): CassandraClient
- execute(String, Collector<Row, Object, Object>): Future<Object>
- execute(Statement, Handler<AsyncResult<ResultSet>>): CassandraClient
- execute(Statement): Future<ResultSet>
- execute(Statement, Collector<Row, Object, Object>, Handler<AsyncResult<Object>>): CassandraClient
- execute(Statement, Collector<Row, Object, Object>): Future<Object>
- prepare(String, Handler<AsyncResult<PreparedStatement>>): CassandraClient
- prepare(String): Future<PreparedStatement>
- prepare(SimpleStatement, Handler<AsyncResult<PreparedStatement>>): CassandraClient
- prepare(SimpleStatement): Future<PreparedStatement>
- queryStream(String, Handler<AsyncResult<CassandraRowStream>>): CassandraClient
- queryStream(String): Future<CassandraRowStream>
- queryStream(Statement, Handler<AsyncResult<CassandraRowStream>>): CassandraClient
- queryStream(Statement): Future<CassandraRowStream>
- close(): Future<Void>
- metadata(Handler<AsyncResult<Metadata>>): void
- metadata(): Future<Metadata>
-
CassandraClientOptions
- DEFAULT_PORT: int
- DEFAULT_HOST: String
- builder: CqlSessionBuilder
- keyspace: String
- CassandraClientOptions(): void
- CassandraClientOptions(CassandraClientOptions): void
- CassandraClientOptions(CqlSessionBuilder): void
- CassandraClientOptions(JsonObject): void
- toJson(): JsonObject
- addContactPoint(InetSocketAddress): CassandraClientOptions
- addContactPoint(String, int): CassandraClientOptions
- dataStaxClusterBuilder(): CqlSessionBuilder
- getKeyspace(): String
- setKeyspace(String): CassandraClientOptions
- CassandraClientOptionsConverter
-
CassandraRowStream
- exceptionHandler(Handler<Throwable>): CassandraRowStream
- handler(Handler<Row>): CassandraRowStream
- pause(): CassandraRowStream
- resume(): CassandraRowStream
- endHandler(Handler<Void>): CassandraRowStream
- fetch(long): CassandraRowStream
- pipeTo(WriteStream<Row>): Future<Void>
- pipeTo(WriteStream<Row>, Handler<AsyncResult<Void>>): void
- executionInfo(): ExecutionInfo
- columnDefinitions(): ColumnDefinitions
-
ResultSet
- all(): Future<List<Row>>
- all(Handler<AsyncResult<List<Row>>>): ResultSet
- getColumnDefinitions(): ColumnDefinitions
- getExecutionInfo(): ExecutionInfo
- remaining(): int
- currentPage(): Iterable<Row>
- one(): Row
- hasMorePages(): boolean
- fetchNextPage(Handler<AsyncResult<ResultSet>>): void
- fetchNextPage(): Future<ResultSet>
- wasApplied(): boolean
-
impl
-
CassandraClientImpl
- HOLDERS_LOCAL_MAP_NAME: String
- vertx: VertxInternal
- clientName: String
- options: CassandraClientOptions
- holders: Map<String, SessionHolder>
- creatingContext: ContextInternal
- closed: boolean
- CassandraClientImpl(Vertx, String, CassandraClientOptions): void
- isConnected(): boolean
- executeWithFullFetch(String, Handler<AsyncResult<List<Row>>>): CassandraClient
- executeWithFullFetch(String): Future<List<Row>>
- executeWithFullFetch(Statement, Handler<AsyncResult<List<Row>>>): CassandraClient
- executeWithFullFetch(Statement): Future<List<Row>>
- execute(String, Handler<AsyncResult<ResultSet>>): CassandraClient
- execute(String): Future<ResultSet>
- execute(String, Collector<Row, Object, Object>, Handler<AsyncResult<Object>>): CassandraClient
- execute(String, Collector<Row, Object, Object>): Future<Object>
- execute(Statement, Handler<AsyncResult<ResultSet>>): CassandraClient
- execute(Statement): Future<ResultSet>
- execute(Statement, Collector<Row, Object, Object>, Handler<AsyncResult<Object>>): CassandraClient
- execute(Statement, Collector<Row, Object, Object>): Future<Object>
- executeAndCollect(Statement, Collector<Row, Object, Object>): Future<Object>
- prepare(String, Handler<AsyncResult<PreparedStatement>>): CassandraClient
- prepare(String): Future<PreparedStatement>
- prepare(SimpleStatement, Handler<AsyncResult<PreparedStatement>>): CassandraClient
- prepare(SimpleStatement): Future<PreparedStatement>
- queryStream(String, Handler<AsyncResult<CassandraRowStream>>): CassandraClient
- queryStream(String): Future<CassandraRowStream>
- queryStream(Statement, Handler<AsyncResult<CassandraRowStream>>): CassandraClient
- queryStream(Statement): Future<CassandraRowStream>
- close(): Future<Void>
- close(Handler<AsyncResult<Void>>): CassandraClient
- metadata(): Future<Metadata>
- metadata(Handler<AsyncResult<Metadata>>): void
- raiseCloseFlag(): boolean
- getSession(ContextInternal): Future<CqlSession>
- connect(Promise<CqlSession>): void
-
CassandraRowStreamImpl
- handler(Handler<Row>): CassandraRowStream
- 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
- pause(): CassandraRowStream
- resume(): CassandraRowStream
- endHandler(Handler<Void>): CassandraRowStream
- fetch(long): CassandraRowStream
- executionInfo(): ExecutionInfo
- columnDefinitions(): ColumnDefinitions
- fetchRow(): void
- handleFetched(Row): void
- handleRow(Row): void
- handleException(Throwable): void
- handleEnd(): void
- stop(): void
-
ResultSetImpl
- vertx: Vertx
- resultSetRef: AtomicReference<AsyncResultSet>
- ResultSetImpl(AsyncResultSet, Vertx): void
- all(Handler<AsyncResult<List<Row>>>): ResultSet
- all(): Future<List<Row>>
- getColumnDefinitions(): ColumnDefinitions
- getExecutionInfo(): ExecutionInfo
- remaining(): int
- currentPage(): Iterable<Row>
- one(): Row
- hasMorePages(): boolean
- fetchNextPage(Handler<AsyncResult<ResultSet>>): void
- fetchNextPage(): Future<ResultSet>
- wasApplied(): boolean
- loadMore(Context, List<Row>, Handler<AsyncResult<List<Row>>>): void
- SessionHolder
- Util
-
CassandraClientImpl
-
CassandraClient
-
cassandra
-
vertx