Uses of Class
org.apache.storm.streams.windowing.SlidingWindows
Packages that use SlidingWindows
-
Uses of SlidingWindows in org.apache.storm.streams.windowing
Methods in org.apache.storm.streams.windowing that return SlidingWindowsModifier 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.