org.apache.storm.cassandra.trident.state

Class CassandraMapStateFactory

java.lang.Object

org.apache.storm.cassandra.trident.state.CassandraMapStateFactory

All Implemented Interfaces:

Serializable, StateFactory

public class CassandraMapStateFactory
extends Object
implements StateFactory

A StateFactory implementation that creates a MapState backed by CassandraBackingMap.

The statefactory supports opaque, transactional and non-transactional configurations. Optionally, the backing map can be wrapped in a CachedMap by specifying withCache(int) (off by default).

See Also:

Serialized Form

Method Summary

Modifier and Type	Method and Description
State	makeState(Map<String,Object> conf, IMetricsContext metrics, int partitionIndex, int numPartitions)
static CassandraMapStateFactory	nonTransactional(CassandraBackingMap.Options options, Map<String,Object> cassandraConfig)
static CassandraMapStateFactory	opaque(CassandraBackingMap.Options options, Map<String,Object> cassandraConfig)
static CassandraMapStateFactory	transactional(CassandraBackingMap.Options options, Map<String,Object> cassandraConfig)
CassandraMapStateFactory	withCache(int cacheSize)

Methods inherited from class java.lang.Object

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

Method Detail

opaque

public static CassandraMapStateFactory opaque(CassandraBackingMap.Options options,
                                              Map<String,Object> cassandraConfig)

transactional

public static CassandraMapStateFactory transactional(CassandraBackingMap.Options options,
                                                     Map<String,Object> cassandraConfig)

nonTransactional

public static CassandraMapStateFactory nonTransactional(CassandraBackingMap.Options options,
                                                        Map<String,Object> cassandraConfig)

withCache

public CassandraMapStateFactory withCache(int cacheSize)

makeState

public State makeState(Map<String,Object> conf,
                       IMetricsContext metrics,
                       int partitionIndex,
                       int numPartitions)

Specified by:

makeState in interface StateFactory