Uses of Class
org.apache.storm.topology.base.BaseStatefulWindowedBolt

Packages that use BaseStatefulWindowedBolt

Package	Description
org.apache.storm.topology.base

Uses of BaseStatefulWindowedBolt in org.apache.storm.topology.base

Methods in org.apache.storm.topology.base that return BaseStatefulWindowedBolt

Modifier and Type	Method	Description
BaseStatefulWindowedBolt<T>	BaseStatefulWindowedBolt.withLag(BaseWindowedBolt.Duration duration)	Specify the maximum time lag of the tuple timestamp in milliseconds.
BaseStatefulWindowedBolt<T>	BaseStatefulWindowedBolt.withLateTupleStream(String streamName)	Specify a stream id on which late tuples are going to be emitted.
BaseStatefulWindowedBolt<T>	BaseStatefulWindowedBolt.withMaxEventsInMemory(long maxEventsInMemory)	The maximum number of window events to keep in memory.
BaseStatefulWindowedBolt<T>	BaseStatefulWindowedBolt.withMessageIdField(String fieldName)	Specify the name of the field in the tuple that holds the message id.
BaseStatefulWindowedBolt<T>	BaseStatefulWindowedBolt.withPersistence()	If set, the stateful windowed bolt would use the backend state for window persistence and only keep a sub-set of events in memory as specified by withMaxEventsInMemory(long).
BaseStatefulWindowedBolt<T>	BaseStatefulWindowedBolt.withTimestampExtractor(TimestampExtractor timestampExtractor)	Specify the timestamp extractor implementation.
BaseStatefulWindowedBolt<T>	BaseStatefulWindowedBolt.withTimestampField(String fieldName)	Specify a field in the tuple that represents the timestamp as a long value.
BaseStatefulWindowedBolt<T>	BaseStatefulWindowedBolt.withTumblingWindow(BaseWindowedBolt.Count count)	A count based tumbling window.
BaseStatefulWindowedBolt<T>	BaseStatefulWindowedBolt.withTumblingWindow(BaseWindowedBolt.Duration duration)	A time duration based tumbling window.
BaseStatefulWindowedBolt<T>	BaseStatefulWindowedBolt.withWatermarkInterval(BaseWindowedBolt.Duration interval)	Specify the watermark event generation interval.
BaseStatefulWindowedBolt<T>	BaseStatefulWindowedBolt.withWindow(BaseWindowedBolt.Count windowLength)	A tuple count based window that slides with every incoming tuple.
BaseStatefulWindowedBolt<T>	BaseStatefulWindowedBolt.withWindow(BaseWindowedBolt.Count windowLength, BaseWindowedBolt.Count slidingInterval)	Tuple count based sliding window configuration.
BaseStatefulWindowedBolt<T>	BaseStatefulWindowedBolt.withWindow(BaseWindowedBolt.Count windowLength, BaseWindowedBolt.Duration slidingInterval)	Tuple count and time duration based sliding window configuration.
BaseStatefulWindowedBolt<T>	BaseStatefulWindowedBolt.withWindow(BaseWindowedBolt.Duration windowLength)	A time duration based window that slides with every incoming tuple.
BaseStatefulWindowedBolt<T>	BaseStatefulWindowedBolt.withWindow(BaseWindowedBolt.Duration windowLength, BaseWindowedBolt.Count slidingInterval)	Time duration and count based sliding window configuration.
BaseStatefulWindowedBolt<T>	BaseStatefulWindowedBolt.withWindow(BaseWindowedBolt.Duration windowLength, BaseWindowedBolt.Duration slidingInterval)	Time duration based sliding window configuration.