org.apache.storm.cassandra.query.impl

Class ObjectMapperCqlStatementMapper

java.lang.Object

org.apache.storm.cassandra.query.impl.ObjectMapperCqlStatementMapper

All Implemented Interfaces:

Serializable, CQLStatementTupleMapper

public class ObjectMapperCqlStatementMapper
extends Object
implements CQLStatementTupleMapper

Tuple mapper that is able to map objects annotated with com.datastax.driver.mapping.annotations.Table to CQL statements.

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
ObjectMapperCqlStatementMapper(String operationField, String valueField, String timestampField, String ttlField, String consistencyLevelField, Collection<com.datastax.driver.core.TypeCodec<?>> codecs, Collection<Class<?>> udtClasses)

Method Summary

Modifier and Type	Method and Description
List<com.datastax.driver.core.Statement>	map(Map<String,Object> map, 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

ObjectMapperCqlStatementMapper

public ObjectMapperCqlStatementMapper(String operationField,
                                      String valueField,
                                      String timestampField,
                                      String ttlField,
                                      String consistencyLevelField,
                                      Collection<com.datastax.driver.core.TypeCodec<?>> codecs,
                                      Collection<Class<?>> udtClasses)

Method Detail

map

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

Description copied from interface: CQLStatementTupleMapper

Maps a given tuple to one or multiple CQL statements.

Specified by:

map in interface CQLStatementTupleMapper

Parameters:

map - the storm configuration map.

session - the cassandra session.

tuple - the incoming tuple to map.

Returns:

a list of Statement.