org.apache.storm.cassandra.query

Interface CQLStatementTupleMapper

All Superinterfaces:

Serializable

All Known Implementing Classes:

BaseCQLStatementTupleMapper, BatchCQLStatementTupleMapper, BoundCQLStatementTupleMapper, CQLStatementTupleMapper.DynamicCQLStatementTupleMapper, ObjectMapperCqlStatementMapper, SimpleCQLStatementMapper

public interface CQLStatementTupleMapper
extends Serializable

Default interface to map a ITuple to a CQL Statement.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	CQLStatementTupleMapper.DynamicCQLStatementTupleMapper

Method Summary

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.

Method Detail

map

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.

Parameters:

conf - the storm configuration map.

session - the cassandra session.

tuple - the incoming tuple to map.

Returns:

a list of Statement.