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 voidPersistentWindowedBoltExecutor.validate(Map<String, Object> topoConf, BaseWindowedBolt.Count windowLengthCount, BaseWindowedBolt.Duration windowLengthDuration, BaseWindowedBolt.Count slidingIntervalCount, BaseWindowedBolt.Duration slidingIntervalDuration) protected voidWindowedBoltExecutor.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.CountBaseWindowedBolt.Count.of(int value) Returns aBaseWindowedBolt.Countof 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.