Package | Description |
---|---|
org.apache.storm.cassandra.trident.state |
Modifier and Type | Class and Description |
---|---|
class |
NonTransactionalTupleStateMapper
State mapper that maps a tuple to separate state fields.
|
class |
OpaqueTupleStateMapper
State mapper that maps an opaque tuple to separate state fields.
|
class |
SerializedStateMapper<T> |
class |
SimpleStateMapper<T> |
class |
TransactionalTupleStateMapper
State mapper that maps a transactional tuple to separate state fields.
|
Modifier and Type | Method and Description |
---|---|
static <U> StateMapper<U> |
SimpleStateMapper.nontransactional(String field) |
static <U> StateMapper<TransactionalValue<U>> |
SimpleStateMapper.opaque(String txIdField,
String field) |
static <U> StateMapper<OpaqueValue<U>> |
SimpleStateMapper.opaque(String txIdField,
String previousField,
String field) |
Modifier and Type | Method and Description |
---|---|
MapStateFactoryBuilder<T> |
MapStateFactoryBuilder.withStateMapper(StateMapper<T> stateMapper) |
CassandraBackingMap.Options<T> |
CassandraBackingMap.Options.withStateMapper(StateMapper<T> stateMapper) |
Copyright © 2019 The Apache Software Foundation. All rights reserved.