org.apache.storm.cassandra.query.impl

Class SimpleCQLStatementMapper

java.lang.Object

org.apache.storm.cassandra.query.impl.SimpleCQLStatementMapper

All Implemented Interfaces:

Serializable, CQLStatementTupleMapper

public class SimpleCQLStatementMapper
extends Object
implements CQLStatementTupleMapper

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.storm.cassandra.query.CQLStatementTupleMapper

CQLStatementTupleMapper.DynamicCQLStatementTupleMapper

Constructor Summary

Constructors

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.

Method Summary

Modifier and Type	Method and Description
List<com.datastax.driver.core.Statement>	map(Map conf, com.datastax.driver.core.Session session, ITuple tuple) Maps a given tuple to one or multiple CQL statements.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SimpleCQLStatementMapper

public SimpleCQLStatementMapper(String queryString,
                                CqlMapper mapper)

Creates a new SimpleCQLStatementMapper instance.

Parameters:

queryString - the cql query string to execute.

mapper - the mapper.

SimpleCQLStatementMapper

public SimpleCQLStatementMapper(String queryString,
                                CqlMapper mapper,
                                RoutingKeyGenerator rkGenerator)

Creates a new SimpleCQLStatementMapper instance.

Parameters:

queryString - the cql query string to execute.

mapper - the mapper.

Method Detail

map

public List<com.datastax.driver.core.Statement> map(Map conf,
                                                    com.datastax.driver.core.Session session,
                                                    ITuple tuple)

Maps a given tuple to one or multiple CQL statements.

.

Specified by:

map in interface CQLStatementTupleMapper

Parameters:

conf - the storm configuration map.

session - the cassandra session.

tuple - the incoming tuple to map.

Returns:

a list of Statement.