Uses of Class
org.apache.storm.topology.base.BaseWindowedBolt.Duration
Package
Description
-
Uses of BaseWindowedBolt.Duration in org.apache.storm.bolt
Modifier 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
Modifier and TypeMethodDescriptionBaseWindow.getLag()
Window.getLag()
The maximum time lag of the tuple timestamp in milliseconds.Modifier 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.Modifier 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
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.Duration in org.apache.storm.topology.base
Modifier 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.Modifier 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
Modifier 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
Modifier and TypeMethodDescriptionstatic SlidingDurationWindow
SlidingDurationWindow.of
(BaseWindowedBolt.Duration windowDuration, BaseWindowedBolt.Duration slidingDuration) static TumblingDurationWindow
TumblingDurationWindow.of
(BaseWindowedBolt.Duration windowLength)