Uses of Class
org.apache.storm.topology.base.BaseWindowedBolt.Duration
Packages that use BaseWindowedBolt.Duration
Package
Description
-
Uses of BaseWindowedBolt.Duration in org.apache.storm.bolt
Methods in org.apache.storm.bolt with parameters of type BaseWindowedBolt.DurationModifier and TypeMethodDescriptionJoinBolt.withLag
(BaseWindowedBolt.Duration duration) JoinBolt.withTumblingWindow
(BaseWindowedBolt.Duration duration) JoinBolt.withWatermarkInterval
(BaseWindowedBolt.Duration interval) JoinBolt.withWindow
(BaseWindowedBolt.Count windowLength, BaseWindowedBolt.Duration slidingInterval) JoinBolt.withWindow
(BaseWindowedBolt.Duration windowLength) JoinBolt.withWindow
(BaseWindowedBolt.Duration windowLength, BaseWindowedBolt.Count slidingInterval) JoinBolt.withWindow
(BaseWindowedBolt.Duration windowLength, BaseWindowedBolt.Duration slidingInterval) -
Uses of BaseWindowedBolt.Duration in org.apache.storm.streams.windowing
Fields in org.apache.storm.streams.windowing declared as BaseWindowedBolt.DurationMethods in org.apache.storm.streams.windowing that return BaseWindowedBolt.DurationModifier and TypeMethodDescriptionBaseWindow.getLag()
Window.getLag()
The maximum time lag of the tuple timestamp in milliseconds.Methods in org.apache.storm.streams.windowing that return types with arguments of type BaseWindowedBolt.DurationModifier and TypeMethodDescriptionSlidingWindows.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.SlidingWindows.of
(BaseWindowedBolt.Duration windowLength, BaseWindowedBolt.Duration slidingInterval) Time duration based sliding window configuration.SlidingWindows.of
(BaseWindowedBolt.Duration windowLength, BaseWindowedBolt.Duration slidingInterval) Time duration based sliding window configuration.TumblingWindows.of
(BaseWindowedBolt.Duration duration) A time duration based tumbling window.Methods in org.apache.storm.streams.windowing with parameters of type BaseWindowedBolt.DurationModifier and TypeMethodDescriptionSlidingWindows.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.SlidingWindows.of
(BaseWindowedBolt.Duration windowLength, BaseWindowedBolt.Duration slidingInterval) Time duration based sliding window configuration.TumblingWindows.of
(BaseWindowedBolt.Duration duration) A time duration based tumbling window.SlidingWindows.withLag
(BaseWindowedBolt.Duration duration) Specify the maximum time lag of the tuple timestamp in milliseconds.TumblingWindows.withLag
(BaseWindowedBolt.Duration duration) Specify the maximum time lag of the tuple timestamp in milliseconds. -
Uses of BaseWindowedBolt.Duration in org.apache.storm.topology
Methods in org.apache.storm.topology with parameters of type BaseWindowedBolt.DurationModifier 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.Duration in org.apache.storm.topology.base
Methods in org.apache.storm.topology.base that return BaseWindowedBolt.DurationModifier and TypeMethodDescriptionstatic BaseWindowedBolt.Duration
BaseWindowedBolt.Duration.days
(int days) Returns aBaseWindowedBolt.Duration
corresponding to the the given value in days.static BaseWindowedBolt.Duration
BaseWindowedBolt.Duration.hours
(int hours) Returns aBaseWindowedBolt.Duration
corresponding to the the given value in hours.static BaseWindowedBolt.Duration
BaseWindowedBolt.Duration.minutes
(int minutes) Returns aBaseWindowedBolt.Duration
corresponding to the the given value in minutes.static BaseWindowedBolt.Duration
BaseWindowedBolt.Duration.of
(int milliseconds) Returns aBaseWindowedBolt.Duration
corresponding to the the given value in milli seconds.static BaseWindowedBolt.Duration
BaseWindowedBolt.Duration.seconds
(int seconds) Returns aBaseWindowedBolt.Duration
corresponding to the the given value in seconds.Methods in org.apache.storm.topology.base with parameters of type BaseWindowedBolt.DurationModifier and TypeMethodDescriptionBaseStatefulWindowedBolt.withLag
(BaseWindowedBolt.Duration duration) Specify the maximum time lag of the tuple timestamp in milliseconds.BaseWindowedBolt.withLag
(BaseWindowedBolt.Duration duration) Specify the maximum time lag of the tuple timestamp in milliseconds.BaseStatefulWindowedBolt.withTumblingWindow
(BaseWindowedBolt.Duration duration) A time duration based tumbling window.BaseWindowedBolt.withTumblingWindow
(BaseWindowedBolt.Duration duration) A time duration based tumbling window.BaseStatefulWindowedBolt.withWatermarkInterval
(BaseWindowedBolt.Duration interval) Specify the watermark event generation interval.BaseWindowedBolt.withWatermarkInterval
(BaseWindowedBolt.Duration interval) Specify the watermark event generation interval.BaseStatefulWindowedBolt.withWindow
(BaseWindowedBolt.Count windowLength, BaseWindowedBolt.Duration slidingInterval) Tuple count and time duration based sliding window configuration.BaseStatefulWindowedBolt.withWindow
(BaseWindowedBolt.Duration windowLength) A time duration based window that slides with every incoming tuple.BaseStatefulWindowedBolt.withWindow
(BaseWindowedBolt.Duration windowLength, BaseWindowedBolt.Count slidingInterval) Time duration and count based sliding window configuration.BaseStatefulWindowedBolt.withWindow
(BaseWindowedBolt.Duration windowLength, BaseWindowedBolt.Duration slidingInterval) Time duration 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) A time duration based window that slides with every incoming tuple.BaseWindowedBolt.withWindow
(BaseWindowedBolt.Duration windowLength, BaseWindowedBolt.Count slidingInterval) Time duration and count based sliding window configuration.BaseWindowedBolt.withWindow
(BaseWindowedBolt.Duration windowLength, BaseWindowedBolt.Duration slidingInterval) Time duration based sliding window configuration. -
Uses of BaseWindowedBolt.Duration in org.apache.storm.trident
Methods in org.apache.storm.trident with parameters of type BaseWindowedBolt.DurationModifier and TypeMethodDescriptionStream.slidingWindow
(BaseWindowedBolt.Duration windowDuration, BaseWindowedBolt.Duration slidingInterval, WindowsStoreFactory windowStoreFactory, Fields inputFields, Aggregator aggregator, Fields functionFields) Returns a stream of tuples which are aggregated results of a window which slides at duration ofslidingInterval
and completes a window atwindowDuration
.Stream.tumblingWindow
(BaseWindowedBolt.Duration windowDuration, WindowsStoreFactory windowStoreFactory, Fields inputFields, Aggregator aggregator, Fields functionFields) Returns a stream of tuples which are aggregated results of a window that tumbles at duration ofwindowDuration
. -
Uses of BaseWindowedBolt.Duration in org.apache.storm.trident.windowing.config
Methods in org.apache.storm.trident.windowing.config with parameters of type BaseWindowedBolt.DurationModifier and TypeMethodDescriptionstatic SlidingDurationWindow
SlidingDurationWindow.of
(BaseWindowedBolt.Duration windowDuration, BaseWindowedBolt.Duration slidingDuration) static TumblingDurationWindow
TumblingDurationWindow.of
(BaseWindowedBolt.Duration windowLength)