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
-
-
-
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
-
-
-
cassandra
-
vertx