Uses of Interface
org.apache.storm.topology.IWindowedBolt
-
-
Uses of IWindowedBolt in org.apache.storm.bolt
Classes in org.apache.storm.bolt that implement IWindowedBolt Modifier and Type Class Description class
JoinBolt
-
Uses of IWindowedBolt in org.apache.storm.flux.examples
Classes in org.apache.storm.flux.examples that implement IWindowedBolt Modifier and Type Class Description class
TestWindowBolt
-
Uses of IWindowedBolt in org.apache.storm.st.topology.window
Classes in org.apache.storm.st.topology.window that implement IWindowedBolt Modifier and Type Class Description class
TimeDataVerificationBolt
class
VerificationBolt
-
Uses of IWindowedBolt in org.apache.storm.starter.bolt
Classes in org.apache.storm.starter.bolt that implement IWindowedBolt Modifier and Type Class Description class
SlidingWindowSumBolt
Computes sliding window sum. -
Uses of IWindowedBolt in org.apache.storm.topology
Subinterfaces of IWindowedBolt in org.apache.storm.topology Modifier and Type Interface Description interface
IStatefulWindowedBolt<T extends State>
A windowed bolt abstraction for supporting windowing operation with state.Methods in org.apache.storm.topology with parameters of type IWindowedBolt Modifier and Type Method Description BoltDeclarer
TopologyBuilder. setBolt(String id, IWindowedBolt bolt)
Define a new bolt in this topology.BoltDeclarer
TopologyBuilder. setBolt(String id, IWindowedBolt bolt, Number parallelismHint)
Define a new bolt in this topology.Constructors in org.apache.storm.topology with parameters of type IWindowedBolt Constructor Description WindowedBoltExecutor(IWindowedBolt bolt)
-
Uses of IWindowedBolt in org.apache.storm.topology.base
Classes in org.apache.storm.topology.base that implement IWindowedBolt Modifier and Type Class Description class
BaseStatefulWindowedBolt<T extends State>
class
BaseWindowedBolt
-