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