Uses of Interface
org.apache.storm.topology.IStatefulBolt
-
Packages that use IStatefulBolt Package Description org.apache.storm.flux.examples org.apache.storm.topology org.apache.storm.topology.base -
-
Uses of IStatefulBolt in org.apache.storm.flux.examples
Classes in org.apache.storm.flux.examples that implement IStatefulBolt Modifier and Type Class Description class
StatefulWordCounter
-
Uses of IStatefulBolt in org.apache.storm.topology
Classes in org.apache.storm.topology that implement IStatefulBolt Modifier and Type Class Description class
PersistentWindowedBoltExecutor<T extends State>
Wraps aIStatefulWindowedBolt
and handles the execution.class
StatefulWindowedBoltExecutor<T extends State>
Wraps aIStatefulWindowedBolt
and handles the execution.Methods in org.apache.storm.topology with parameters of type IStatefulBolt Modifier and Type Method Description <T extends State>
BoltDeclarerTopologyBuilder. setBolt(String id, IStatefulBolt<T> bolt)
Define a new bolt in this topology.<T extends State>
BoltDeclarerTopologyBuilder. setBolt(String id, IStatefulBolt<T> bolt, Number parallelismHint)
Define a new bolt in this topology.Constructors in org.apache.storm.topology with parameters of type IStatefulBolt Constructor Description StatefulBoltExecutor(IStatefulBolt<T> bolt)
-
Uses of IStatefulBolt in org.apache.storm.topology.base
Classes in org.apache.storm.topology.base that implement IStatefulBolt Modifier and Type Class Description class
BaseStatefulBolt<T extends State>
-