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