Package | Description |
---|---|
org.apache.storm.cassandra | |
org.apache.storm.cassandra.query | |
org.apache.storm.cassandra.query.builder | |
org.apache.storm.cassandra.query.impl |
Modifier and Type | Method and Description |
---|---|
static ContextQuery |
DynamicStatementBuilder.named(String name)
Retrieves from the storm configuration the specified named query.
|
static ContextQuery |
DynamicStatementBuilder.namedByField(String fieldName)
Retrieves from the storm configuration the named query specified by a tuple field.
|
Modifier and Type | Method and Description |
---|---|
static BoundCQLStatementMapperBuilder |
DynamicStatementBuilder.boundQuery(ContextQuery field)
Builds a new bound statement identified by the given field.
|
Modifier and Type | Class and Description |
---|---|
static class |
ContextQuery.BoundQueryContext
Default
ContextQuery.BoundQueryContext implementation to retrieve a bound query identified by the provided key. |
static class |
ContextQuery.BoundQueryNamedByFieldContext
Default
ContextQuery.BoundQueryNamedByFieldContext implementation to retrieve a bound query named by the value of a specified tuple field. |
static class |
ContextQuery.StaticContextQuery
Static implementation of
ContextQuery interface. |
Constructor and Description |
---|
BoundCQLStatementMapperBuilder(ContextQuery contextQuery)
Creates a new
BoundCQLStatementMapperBuilder instance. |
Constructor and Description |
---|
BoundCQLStatementTupleMapper(ContextQuery contextQuery,
CqlMapper mapper,
RoutingKeyGenerator rkGenerator,
PreparedStatementBinder binder)
Creates a new
BoundCQLStatementTupleMapper instance. |
Copyright © 2020 The Apache Software Foundation. All rights reserved.