Uses of Class
org.apache.storm.topology.base.BaseWindowedBolt.Count
Packages that use BaseWindowedBolt.Count
Package
Description
-
Uses of BaseWindowedBolt.Count in org.apache.storm.bolt
Methods in org.apache.storm.bolt with parameters of type BaseWindowedBolt.CountModifier 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
Methods in org.apache.storm.streams.windowing that return types with arguments of type BaseWindowedBolt.CountModifier 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.Methods in org.apache.storm.streams.windowing with parameters of type BaseWindowedBolt.CountModifier 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
Methods in org.apache.storm.topology with parameters of type BaseWindowedBolt.CountModifier 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
Methods in org.apache.storm.topology.base that return BaseWindowedBolt.CountModifier and TypeMethodDescriptionstatic BaseWindowedBolt.Count
BaseWindowedBolt.Count.of
(int value) Returns aBaseWindowedBolt.Count
of given value.Methods in org.apache.storm.topology.base with parameters of type BaseWindowedBolt.CountModifier 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.