org.apache.storm.cassandra.query.impl

Class BatchCQLStatementTupleMapper

java.lang.Object

org.apache.storm.cassandra.query.impl.BatchCQLStatementTupleMapper

All Implemented Interfaces:

Serializable, CQLStatementTupleMapper

public class BatchCQLStatementTupleMapper
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
BatchCQLStatementTupleMapper(com.datastax.driver.core.BatchStatement.Type type, List<CQLStatementTupleMapper> mappers) Creates a new BatchCQLStatementTupleMapper 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

BatchCQLStatementTupleMapper

public BatchCQLStatementTupleMapper(com.datastax.driver.core.BatchStatement.Type type,
                                    List<CQLStatementTupleMapper> mappers)

Creates a new BatchCQLStatementTupleMapper instance.

Parameters:

type -

mappers -

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.