Package | Description |
---|---|
org.apache.storm.hbase.state | |
org.apache.storm.redis.state | |
org.apache.storm.state | |
org.apache.storm.topology | |
org.apache.storm.topology.base |
Modifier and Type | Class and Description |
---|---|
class |
HBaseKeyValueState<K,V>
A Hbase based implementation that persists the state in HBase.
|
Modifier and Type | Method and Description |
---|---|
State |
HBaseKeyValueStateProvider.newState(String namespace,
Map stormConf,
TopologyContext context) |
Modifier and Type | Class and Description |
---|---|
class |
RedisKeyValueState<K,V>
A redis based implementation that persists the state in Redis.
|
Modifier and Type | Method and Description |
---|---|
State |
RedisKeyValueStateProvider.newState(String namespace,
Map stormConf,
TopologyContext context) |
Modifier and Type | Interface and Description |
---|---|
interface |
KeyValueState<K,V>
A state that supports key-value mappings.
|
Modifier and Type | Class and Description |
---|---|
class |
InMemoryKeyValueState<K,V>
An in-memory implementation of the
State |
Modifier and Type | Method and Description |
---|---|
static State |
StateFactory.getState(String namespace,
Map stormConf,
TopologyContext context)
Returns a new state instance using the
Config.TOPOLOGY_STATE_PROVIDER or a InMemoryKeyValueState if no provider is configured. |
State |
StateProvider.newState(String namespace,
Map stormConf,
TopologyContext context)
Returns a new state instance.
|
State |
InMemoryKeyValueStateProvider.newState(String namespace,
Map stormConf,
TopologyContext context) |
Modifier and Type | Interface and Description |
---|---|
interface |
IStatefulBolt<T extends State>
A bolt abstraction for supporting stateful computation.
|
interface |
IStatefulComponent<T extends State>
Common methods for stateful components in the topology.
|
interface |
IStatefulWindowedBolt<T extends State>
A windowed bolt abstraction for supporting windowing operation with state
|
class |
StatefulBoltExecutor<T extends State>
Wraps a
IStatefulBolt and manages the state of the bolt. |
class |
StatefulWindowedBoltExecutor<T extends State>
Wraps a
IStatefulWindowedBolt and handles the execution. |
Modifier and Type | Method and Description |
---|---|
<T extends State> |
TopologyBuilder.setBolt(String id,
IStatefulBolt<T> bolt)
Define a new bolt in this topology.
|
<T extends State> |
TopologyBuilder.setBolt(String id,
IStatefulBolt<T> bolt,
Number parallelism_hint)
Define a new bolt in this topology.
|
<T extends State> |
TopologyBuilder.setBolt(String id,
IStatefulWindowedBolt<T> bolt)
Define a new bolt in this topology.
|
<T extends State> |
TopologyBuilder.setBolt(String id,
IStatefulWindowedBolt<T> bolt,
Number parallelism_hint)
Define a new bolt in this topology.
|
Modifier and Type | Class and Description |
---|---|
class |
BaseStatefulBolt<T extends State> |
class |
BaseStatefulWindowedBolt<T extends State> |
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.