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