public static class CQLStatementTupleMapper.DynamicCQLStatementTupleMapper extends Object implements CQLStatementTupleMapper
CQLStatementTupleMapper.DynamicCQLStatementTupleMapper| Constructor and Description |
|---|
DynamicCQLStatementTupleMapper(List<CQLStatementBuilder> builders) |
| 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 DynamicCQLStatementTupleMapper(List<CQLStatementBuilder> builders)
public List<com.datastax.driver.core.Statement> map(Map<String,Object> conf, com.datastax.driver.core.Session session, ITuple tuple)
CQLStatementTupleMapperMaps 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.