Modifier and Type | Method and Description |
---|---|
static CQLStatementTupleMapper |
DynamicStatementBuilder.async(CQLStatementBuilder... builders)
Builds multiple statements which will be executed asynchronously.
|
Modifier and Type | Method and Description |
---|---|
protected CQLStatementTupleMapper |
BaseCassandraBolt.getMapper() |
Constructor and Description |
---|
BaseCassandraBolt(CQLStatementTupleMapper tupleMapper)
Creates a new
CassandraWriterBolt instance. |
BaseCassandraBolt(CQLStatementTupleMapper mapper,
SimpleClientProvider clientProvider)
Creates a new
CassandraWriterBolt instance. |
BatchCassandraWriterBolt(CQLStatementTupleMapper tupleMapper)
Creates a new
CassandraWriterBolt instance. |
BatchCassandraWriterBolt(CQLStatementTupleMapper tupleMapper,
int tickFrequencyInSeconds)
Creates a new
CassandraWriterBolt instance. |
CassandraWriterBolt(CQLStatementTupleMapper tupleMapper)
Creates a new
CassandraWriterBolt instance. |
Modifier and Type | Interface and Description |
---|---|
interface |
CQLStatementBuilder<T extends CQLStatementTupleMapper> |
Modifier and Type | Class and Description |
---|---|
class |
BaseCQLStatementTupleMapper
Default interface to map a
ITuple to a CQL Statement . |
static class |
CQLStatementTupleMapper.DynamicCQLStatementTupleMapper |
Modifier and Type | Class and Description |
---|---|
class |
BatchCQLStatementTupleMapper |
class |
BoundCQLStatementTupleMapper |
class |
ObjectMapperCqlStatementMapper
Tuple mapper that is able to map objects annotated with
Table to CQL statements. |
class |
SimpleCQLStatementMapper |
Constructor and Description |
---|
BatchCQLStatementTupleMapper(com.datastax.driver.core.BatchStatement.Type type,
List<CQLStatementTupleMapper> mappers)
Creates a new
BatchCQLStatementTupleMapper instance. |
Modifier and Type | Method and Description |
---|---|
CassandraState.Options |
CassandraState.Options.withCQLStatementTupleMapper(CQLStatementTupleMapper cqlStatementTupleMapper) |
CassandraBackingMap.Options<T> |
CassandraBackingMap.Options.withGetMapper(CQLStatementTupleMapper getMapper) |
CassandraBackingMap.Options<T> |
CassandraBackingMap.Options.withPutMapper(CQLStatementTupleMapper putMapper) |
Constructor and Description |
---|
CassandraStateFactory(CQLStatementTupleMapper cqlStatementTupleMapper,
CQLResultSetValuesMapper cqlResultSetValuesMapper) |
Copyright © 2023 The Apache Software Foundation. All rights reserved.