Uses of Class
org.apache.storm.topology.base.BaseWindowedBolt
Package
Description
-
Uses of BaseWindowedBolt in org.apache.storm.bolt
Modifier and TypeMethodDescriptionJoinBolt.withLag
(BaseWindowedBolt.Duration duration) JoinBolt.withWatermarkInterval
(BaseWindowedBolt.Duration interval) -
Uses of BaseWindowedBolt in org.apache.storm.flux.examples
-
Uses of BaseWindowedBolt in org.apache.storm.st.topology.window
-
Uses of BaseWindowedBolt in org.apache.storm.starter.bolt
-
Uses of BaseWindowedBolt in org.apache.storm.topology.base
Modifier and TypeMethodDescriptionBaseWindowedBolt.withLag
(BaseWindowedBolt.Duration duration) Specify the maximum time lag of the tuple timestamp in milliseconds.BaseWindowedBolt.withLateTupleStream
(String streamId) Specify a stream id on which late tuples are going to be emitted.BaseWindowedBolt.withTimestampExtractor
(TimestampExtractor timestampExtractor) Specify the timestamp extractor implementation.BaseWindowedBolt.withTimestampField
(String fieldName) Specify a field in the tuple that represents the timestamp as a long value.BaseWindowedBolt.withTumblingWindow
(BaseWindowedBolt.Count count) A count based tumbling window.BaseWindowedBolt.withTumblingWindow
(BaseWindowedBolt.Duration duration) A time duration based tumbling window.BaseWindowedBolt.withWatermarkInterval
(BaseWindowedBolt.Duration interval) Specify the watermark event generation interval.BaseWindowedBolt.withWindow
(BaseWindowedBolt.Count windowLength) A tuple count based window that slides with every incoming tuple.BaseWindowedBolt.withWindow
(BaseWindowedBolt.Count windowLength, BaseWindowedBolt.Count slidingInterval) Tuple count 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.