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 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.Duration in org.apache.storm.topology.base
Methods in org.apache.storm.topology.base that return BaseWindowedBolt.DurationModifier and TypeMethodDescriptionstatic BaseWindowedBolt.DurationBaseWindowedBolt.Duration.days(int days) Returns aBaseWindowedBolt.Durationcorresponding to the the given value in days.static BaseWindowedBolt.DurationBaseWindowedBolt.Duration.hours(int hours) Returns aBaseWindowedBolt.Durationcorresponding to the the given value in hours.static BaseWindowedBolt.DurationBaseWindowedBolt.Duration.minutes(int minutes) Returns aBaseWindowedBolt.Durationcorresponding to the the given value in minutes.static BaseWindowedBolt.DurationBaseWindowedBolt.Duration.of(int milliseconds) Returns aBaseWindowedBolt.Durationcorresponding to the the given value in milli seconds.static BaseWindowedBolt.DurationBaseWindowedBolt.Duration.seconds(int seconds) Returns aBaseWindowedBolt.Durationcorresponding 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 ofslidingIntervaland 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 SlidingDurationWindowSlidingDurationWindow.of(BaseWindowedBolt.Duration windowDuration, BaseWindowedBolt.Duration slidingDuration) static TumblingDurationWindowTumblingDurationWindow.of(BaseWindowedBolt.Duration windowLength)