org.apache.storm.cassandra.trident.state

Class NonTransactionalTupleStateMapper

java.lang.Object

org.apache.storm.cassandra.trident.state.NonTransactionalTupleStateMapper

All Implemented Interfaces:

Serializable, StateMapper<ITuple>

public class NonTransactionalTupleStateMapper
extends Object
implements StateMapper<ITuple>

State mapper that maps a tuple to separate state fields.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
NonTransactionalTupleStateMapper(Fields fields)
NonTransactionalTupleStateMapper(String... fields)

Method Summary

Modifier and Type	Method and Description
ITuple	fromValues(List<Values> values)
Fields	getStateFields()
String	toString()
Values	toValues(ITuple t)

Methods inherited from class java.lang.Object

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

Constructor Detail

NonTransactionalTupleStateMapper

public NonTransactionalTupleStateMapper(String... fields)

NonTransactionalTupleStateMapper

public NonTransactionalTupleStateMapper(Fields fields)

Method Detail

getStateFields

public Fields getStateFields()

Specified by:

getStateFields in interface StateMapper<ITuple>

toValues

public Values toValues(ITuple t)

Specified by:

toValues in interface StateMapper<ITuple>

fromValues

public ITuple fromValues(List<Values> values)

Specified by:

fromValues in interface StateMapper<ITuple>

toString

public String toString()

Overrides:

toString in class Object