Uses of Class
org.apache.storm.topology.base.BaseWindowedBolt.Count
Package
Description
-
Uses of BaseWindowedBolt.Count in org.apache.storm.bolt
Modifier and TypeMethodDescriptionJoinBolt.withTumblingWindow
(BaseWindowedBolt.Count count) JoinBolt.withWindow
(BaseWindowedBolt.Count windowLength) JoinBolt.withWindow
(BaseWindowedBolt.Count windowLength, BaseWindowedBolt.Count slidingInterval) JoinBolt.withWindow
(BaseWindowedBolt.Count windowLength, BaseWindowedBolt.Duration slidingInterval) JoinBolt.withWindow
(BaseWindowedBolt.Duration windowLength, BaseWindowedBolt.Count slidingInterval) -
Uses of BaseWindowedBolt.Count in org.apache.storm.streams.windowing
Modifier and TypeMethodDescriptionSlidingWindows.of
(BaseWindowedBolt.Count windowLength, BaseWindowedBolt.Count slidingInterval) Count based sliding window configuration.SlidingWindows.of
(BaseWindowedBolt.Count windowLength, BaseWindowedBolt.Count slidingInterval) Count based sliding window configuration.SlidingWindows.of
(BaseWindowedBolt.Count windowLength, BaseWindowedBolt.Duration slidingInterval) Tuple count and time duration based sliding window configuration.SlidingWindows.of
(BaseWindowedBolt.Duration windowLength, BaseWindowedBolt.Count slidingInterval) Time duration and count based sliding window configuration.TumblingWindows.of
(BaseWindowedBolt.Count count) A count based tumbling window.Modifier and TypeMethodDescriptionSlidingWindows.of
(BaseWindowedBolt.Count windowLength, BaseWindowedBolt.Count slidingInterval) Count based sliding window configuration.SlidingWindows.of
(BaseWindowedBolt.Count windowLength, BaseWindowedBolt.Duration slidingInterval) Tuple count and time duration based sliding window configuration.SlidingWindows.of
(BaseWindowedBolt.Duration windowLength, BaseWindowedBolt.Count slidingInterval) Time duration and count based sliding window configuration.TumblingWindows.of
(BaseWindowedBolt.Count count) A count based tumbling window. -
Uses of BaseWindowedBolt.Count in org.apache.storm.topology
Modifier and TypeMethodDescriptionprotected void
PersistentWindowedBoltExecutor.validate
(Map<String, Object> topoConf, BaseWindowedBolt.Count windowLengthCount, BaseWindowedBolt.Duration windowLengthDuration, BaseWindowedBolt.Count slidingIntervalCount, BaseWindowedBolt.Duration slidingIntervalDuration) protected void
WindowedBoltExecutor.validate
(Map<String, Object> topoConf, BaseWindowedBolt.Count windowLengthCount, BaseWindowedBolt.Duration windowLengthDuration, BaseWindowedBolt.Count slidingIntervalCount, BaseWindowedBolt.Duration slidingIntervalDuration) -
Uses of BaseWindowedBolt.Count in org.apache.storm.topology.base
Modifier and TypeMethodDescriptionstatic BaseWindowedBolt.Count
BaseWindowedBolt.Count.of
(int value) Returns aBaseWindowedBolt.Count
of given value.Modifier and TypeMethodDescriptionBaseStatefulWindowedBolt.withTumblingWindow
(BaseWindowedBolt.Count count) A count based tumbling window.BaseWindowedBolt.withTumblingWindow
(BaseWindowedBolt.Count count) A count based tumbling window.BaseStatefulWindowedBolt.withWindow
(BaseWindowedBolt.Count windowLength) A tuple count based window that slides with every incoming tuple.BaseStatefulWindowedBolt.withWindow
(BaseWindowedBolt.Count windowLength, BaseWindowedBolt.Count slidingInterval) Tuple count based sliding window configuration.BaseStatefulWindowedBolt.withWindow
(BaseWindowedBolt.Count windowLength, BaseWindowedBolt.Duration slidingInterval) Tuple count and time duration based sliding window configuration.BaseStatefulWindowedBolt.withWindow
(BaseWindowedBolt.Duration windowLength, BaseWindowedBolt.Count slidingInterval) Time duration and count based sliding window configuration.BaseWindowedBolt.withWindow
(BaseWindowedBolt.Count windowLength) A tuple count based window that slides with every incoming tuple.BaseWindowedBolt.withWindow
(BaseWindowedBolt.Count windowLength, BaseWindowedBolt.Count slidingInterval) Tuple count based sliding window configuration.BaseWindowedBolt.withWindow
(BaseWindowedBolt.Count windowLength, BaseWindowedBolt.Duration slidingInterval) Tuple count and time duration based sliding window configuration.BaseWindowedBolt.withWindow
(BaseWindowedBolt.Duration windowLength, BaseWindowedBolt.Count slidingInterval) Time duration and count based sliding window configuration.