Uses of Class
org.apache.storm.streams.windowing.SlidingWindows
-
Uses of SlidingWindows in org.apache.storm.streams.windowing
Modifier 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.SlidingWindows.of
(BaseWindowedBolt.Duration windowLength, BaseWindowedBolt.Duration slidingInterval) Time duration based sliding window configuration.SlidingWindows.withLag
(BaseWindowedBolt.Duration duration) Specify the maximum time lag of the tuple timestamp in milliseconds.SlidingWindows.withLateTupleStream
(String streamId) Specify a stream id on which late tuples are going to be emitted.SlidingWindows.withTimestampField
(String fieldName) The name of the field in the tuple that contains the timestamp when the event occurred as a long value.