public interface CQLStatementTupleMapper extends Serializable
Default interface to map a ITuple
to a CQL Statement
.
Modifier and Type | Interface and Description |
---|---|
static class |
CQLStatementTupleMapper.DynamicCQLStatementTupleMapper |
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.
|
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.
conf
- the storm configuration map.session
- the cassandra session.tuple
- the incoming tuple to map.Statement
.Copyright © 2022 The Apache Software Foundation. All rights reserved.