Uses of Class
org.apache.storm.streams.windowing.TumblingWindows
-
Uses of TumblingWindows in org.apache.storm.streams.windowing
Modifier and TypeMethodDescriptionTumblingWindows.of
(BaseWindowedBolt.Count count) A count based tumbling window.TumblingWindows.of
(BaseWindowedBolt.Duration duration) A time duration based tumbling window.TumblingWindows.withLag
(BaseWindowedBolt.Duration duration) Specify the maximum time lag of the tuple timestamp in milliseconds.TumblingWindows.withLateTupleStream
(String streamId) Specify a stream id on which late tuples are going to be emitted.TumblingWindows.withTimestampField
(String fieldName) The name of the field in the tuple that contains the timestamp when the event occurred as a long value.