public class BoundCQLStatementTupleMapper extends Object implements CQLStatementTupleMapper
CQLStatementTupleMapper.DynamicCQLStatementTupleMapper| Constructor and Description |
|---|
BoundCQLStatementTupleMapper(ContextQuery contextQuery,
CqlMapper mapper,
RoutingKeyGenerator rkGenerator,
PreparedStatementBinder binder)
Creates a new
BoundCQLStatementTupleMapper instance. |
| Modifier and Type | Method and Description |
|---|---|
List<com.datastax.driver.core.Statement> |
map(Map<String,Object> config,
com.datastax.driver.core.Session session,
ITuple tuple)
Maps a given tuple to one or multiple CQL statements.
|
public BoundCQLStatementTupleMapper(ContextQuery contextQuery, CqlMapper mapper, RoutingKeyGenerator rkGenerator, PreparedStatementBinder binder)
Creates a new BoundCQLStatementTupleMapper instance.
public List<com.datastax.driver.core.Statement> map(Map<String,Object> config, com.datastax.driver.core.Session session, ITuple tuple)
Maps a given tuple to one or multiple CQL statements.
map in interface CQLStatementTupleMapperconfig - the storm configuration map.session - the cassandra session.tuple - the incoming tuple to map.Statement.Copyright © 2021 The Apache Software Foundation. All rights reserved.