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).
| 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) |
public static CassandraMapStateFactory opaque(CassandraBackingMap.Options options, Map<String,Object> cassandraConfig)
public static CassandraMapStateFactory transactional(CassandraBackingMap.Options options, Map<String,Object> cassandraConfig)
public static CassandraMapStateFactory nonTransactional(CassandraBackingMap.Options options, Map<String,Object> cassandraConfig)
public CassandraMapStateFactory withCache(int cacheSize)
public State makeState(Map<String,Object> conf, IMetricsContext metrics, int partitionIndex, int numPartitions)
makeState in interface StateFactoryCopyright © 2021 The Apache Software Foundation. All rights reserved.