Uses of Class
org.apache.storm.topology.base.BaseWindowedBolt
Packages that use BaseWindowedBolt
Package
Description
-
Uses of BaseWindowedBolt in org.apache.storm.bolt
Subclasses of BaseWindowedBolt in org.apache.storm.boltMethods in org.apache.storm.bolt that return BaseWindowedBoltModifier and TypeMethodDescriptionJoinBolt.withLag(BaseWindowedBolt.Duration duration) JoinBolt.withWatermarkInterval(BaseWindowedBolt.Duration interval) -
Uses of BaseWindowedBolt in org.apache.storm.flux.examples
Subclasses of BaseWindowedBolt in org.apache.storm.flux.examples -
Uses of BaseWindowedBolt in org.apache.storm.st.topology.window
Subclasses of BaseWindowedBolt in org.apache.storm.st.topology.window -
Uses of BaseWindowedBolt in org.apache.storm.starter.bolt
Subclasses of BaseWindowedBolt in org.apache.storm.starter.bolt -
Uses of BaseWindowedBolt in org.apache.storm.topology.base
Subclasses of BaseWindowedBolt in org.apache.storm.topology.baseMethods in org.apache.storm.topology.base that return BaseWindowedBoltModifier 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.