Uses of Class
org.apache.storm.topology.base.BaseWindowedBolt.Duration

Packages that use BaseWindowedBolt.Duration

Package	Description
org.apache.storm.bolt
org.apache.storm.streams.windowing
org.apache.storm.topology
org.apache.storm.topology.base
org.apache.storm.trident
org.apache.storm.trident.windowing.config

Uses of BaseWindowedBolt.Duration in org.apache.storm.bolt

Methods in org.apache.storm.bolt with parameters of type BaseWindowedBolt.Duration

Modifier and Type	Method and Description
BaseWindowedBolt	JoinBolt.withLag(BaseWindowedBolt.Duration duration)
JoinBolt	JoinBolt.withTumblingWindow(BaseWindowedBolt.Duration duration)
BaseWindowedBolt	JoinBolt.withWatermarkInterval(BaseWindowedBolt.Duration interval)
JoinBolt	JoinBolt.withWindow(BaseWindowedBolt.Count windowLength, BaseWindowedBolt.Duration slidingInterval)
JoinBolt	JoinBolt.withWindow(BaseWindowedBolt.Duration windowLength)
JoinBolt	JoinBolt.withWindow(BaseWindowedBolt.Duration windowLength, BaseWindowedBolt.Count slidingInterval)
JoinBolt	JoinBolt.withWindow(BaseWindowedBolt.Duration windowLength, BaseWindowedBolt.Duration slidingInterval)

Uses of BaseWindowedBolt.Duration in org.apache.storm.streams.windowing

Fields in org.apache.storm.streams.windowing declared as BaseWindowedBolt.Duration

Modifier and Type	Field and Description
protected BaseWindowedBolt.Duration	BaseWindow.lag

Methods in org.apache.storm.streams.windowing that return BaseWindowedBolt.Duration

Modifier and Type	Method and Description
BaseWindowedBolt.Duration	BaseWindow.getLag()
BaseWindowedBolt.Duration	Window.getLag() The maximum time lag of the tuple timestamp in milliseconds.

Methods in org.apache.storm.streams.windowing that return types with arguments of type BaseWindowedBolt.Duration

Modifier and Type	Method and Description
static SlidingWindows<BaseWindowedBolt.Count,BaseWindowedBolt.Duration>	SlidingWindows.of(BaseWindowedBolt.Count windowLength, BaseWindowedBolt.Duration slidingInterval) Tuple count and time duration based sliding window configuration.
static TumblingWindows<BaseWindowedBolt.Duration>	TumblingWindows.of(BaseWindowedBolt.Duration duration) A time duration based tumbling window.
static SlidingWindows<BaseWindowedBolt.Duration,BaseWindowedBolt.Count>	SlidingWindows.of(BaseWindowedBolt.Duration windowLength, BaseWindowedBolt.Count slidingInterval) Time duration and count based sliding window configuration.
static SlidingWindows<BaseWindowedBolt.Duration,BaseWindowedBolt.Duration>	SlidingWindows.of(BaseWindowedBolt.Duration windowLength, BaseWindowedBolt.Duration slidingInterval) Time duration based sliding window configuration.
static SlidingWindows<BaseWindowedBolt.Duration,BaseWindowedBolt.Duration>	SlidingWindows.of(BaseWindowedBolt.Duration windowLength, BaseWindowedBolt.Duration slidingInterval) Time duration based sliding window configuration.

Methods in org.apache.storm.streams.windowing with parameters of type BaseWindowedBolt.Duration

Modifier and Type	Method and Description
static SlidingWindows<BaseWindowedBolt.Count,BaseWindowedBolt.Duration>	SlidingWindows.of(BaseWindowedBolt.Count windowLength, BaseWindowedBolt.Duration slidingInterval) Tuple count and time duration based sliding window configuration.
static TumblingWindows<BaseWindowedBolt.Duration>	TumblingWindows.of(BaseWindowedBolt.Duration duration) A time duration based tumbling window.
static SlidingWindows<BaseWindowedBolt.Duration,BaseWindowedBolt.Count>	SlidingWindows.of(BaseWindowedBolt.Duration windowLength, BaseWindowedBolt.Count slidingInterval) Time duration and count based sliding window configuration.
static SlidingWindows<BaseWindowedBolt.Duration,BaseWindowedBolt.Duration>	SlidingWindows.of(BaseWindowedBolt.Duration windowLength, BaseWindowedBolt.Duration slidingInterval) Time duration based sliding window configuration.
TumblingWindows<L>	TumblingWindows.withLag(BaseWindowedBolt.Duration duration) Specify the maximum time lag of the tuple timestamp in milliseconds.
SlidingWindows<L,I>	SlidingWindows.withLag(BaseWindowedBolt.Duration duration) Specify the maximum time lag of the tuple timestamp in milliseconds.

Uses of BaseWindowedBolt.Duration in org.apache.storm.topology

Methods in org.apache.storm.topology with parameters of type BaseWindowedBolt.Duration

Modifier and Type	Method and Description
protected void	PersistentWindowedBoltExecutor.validate(Map<String,Object> topoConf, BaseWindowedBolt.Count windowLengthCount, BaseWindowedBolt.Duration windowLengthDuration, BaseWindowedBolt.Count slidingIntervalCount, BaseWindowedBolt.Duration slidingIntervalDuration)
protected void	WindowedBoltExecutor.validate(Map<String,Object> topoConf, BaseWindowedBolt.Count windowLengthCount, BaseWindowedBolt.Duration windowLengthDuration, BaseWindowedBolt.Count slidingIntervalCount, BaseWindowedBolt.Duration slidingIntervalDuration)

Uses of BaseWindowedBolt.Duration in org.apache.storm.topology.base

Methods in org.apache.storm.topology.base that return BaseWindowedBolt.Duration

Modifier and Type	Method and Description
static BaseWindowedBolt.Duration	BaseWindowedBolt.Duration.days(int days) Returns a BaseWindowedBolt.Duration corresponding to the the given value in days.
static BaseWindowedBolt.Duration	BaseWindowedBolt.Duration.hours(int hours) Returns a BaseWindowedBolt.Duration corresponding to the the given value in hours.
static BaseWindowedBolt.Duration	BaseWindowedBolt.Duration.minutes(int minutes) Returns a BaseWindowedBolt.Duration corresponding to the the given value in minutes.
static BaseWindowedBolt.Duration	BaseWindowedBolt.Duration.of(int milliseconds) Returns a BaseWindowedBolt.Duration corresponding to the the given value in milli seconds.
static BaseWindowedBolt.Duration	BaseWindowedBolt.Duration.seconds(int seconds) Returns a BaseWindowedBolt.Duration corresponding to the the given value in seconds.

Methods in org.apache.storm.topology.base with parameters of type BaseWindowedBolt.Duration

Modifier and Type	Method and Description
BaseWindowedBolt	BaseWindowedBolt.withLag(BaseWindowedBolt.Duration duration) Specify the maximum time lag of the tuple timestamp in milliseconds.
BaseStatefulWindowedBolt<T>	BaseStatefulWindowedBolt.withLag(BaseWindowedBolt.Duration duration) Specify the maximum time lag of the tuple timestamp in milliseconds.
BaseWindowedBolt	BaseWindowedBolt.withTumblingWindow(BaseWindowedBolt.Duration duration) A time duration based tumbling window.
BaseStatefulWindowedBolt<T>	BaseStatefulWindowedBolt.withTumblingWindow(BaseWindowedBolt.Duration duration) A time duration based tumbling window.
BaseWindowedBolt	BaseWindowedBolt.withWatermarkInterval(BaseWindowedBolt.Duration interval) Specify the watermark event generation interval.
BaseStatefulWindowedBolt<T>	BaseStatefulWindowedBolt.withWatermarkInterval(BaseWindowedBolt.Duration interval) Specify the watermark event generation interval.
BaseWindowedBolt	BaseWindowedBolt.withWindow(BaseWindowedBolt.Count windowLength, BaseWindowedBolt.Duration slidingInterval) Tuple count and time duration based sliding window configuration.
BaseStatefulWindowedBolt<T>	BaseStatefulWindowedBolt.withWindow(BaseWindowedBolt.Count windowLength, BaseWindowedBolt.Duration slidingInterval) Tuple count and time duration based sliding window configuration.
BaseWindowedBolt	BaseWindowedBolt.withWindow(BaseWindowedBolt.Duration windowLength) A time duration based window that slides with every incoming tuple.
BaseStatefulWindowedBolt<T>	BaseStatefulWindowedBolt.withWindow(BaseWindowedBolt.Duration windowLength) A time duration based window that slides with every incoming tuple.
BaseWindowedBolt	BaseWindowedBolt.withWindow(BaseWindowedBolt.Duration windowLength, BaseWindowedBolt.Count slidingInterval) Time duration and count based sliding window configuration.
BaseStatefulWindowedBolt<T>	BaseStatefulWindowedBolt.withWindow(BaseWindowedBolt.Duration windowLength, BaseWindowedBolt.Count slidingInterval) Time duration and count based sliding window configuration.
BaseWindowedBolt	BaseWindowedBolt.withWindow(BaseWindowedBolt.Duration windowLength, BaseWindowedBolt.Duration slidingInterval) Time duration based sliding window configuration.
BaseStatefulWindowedBolt<T>	BaseStatefulWindowedBolt.withWindow(BaseWindowedBolt.Duration windowLength, BaseWindowedBolt.Duration slidingInterval) Time duration based sliding window configuration.

Uses of BaseWindowedBolt.Duration in org.apache.storm.trident

Methods in org.apache.storm.trident with parameters of type BaseWindowedBolt.Duration

Modifier and Type	Method and Description
Stream	Stream.slidingWindow(BaseWindowedBolt.Duration windowDuration, BaseWindowedBolt.Duration slidingInterval, WindowsStoreFactory windowStoreFactory, Fields inputFields, Aggregator aggregator, Fields functionFields) Returns a stream of tuples which are aggregated results of a window which slides at duration of slidingInterval and completes a window at windowDuration.
Stream	Stream.tumblingWindow(BaseWindowedBolt.Duration windowDuration, WindowsStoreFactory windowStoreFactory, Fields inputFields, Aggregator aggregator, Fields functionFields) Returns a stream of tuples which are aggregated results of a window that tumbles at duration of windowDuration.

Uses of BaseWindowedBolt.Duration in org.apache.storm.trident.windowing.config

Methods in org.apache.storm.trident.windowing.config with parameters of type BaseWindowedBolt.Duration

Modifier and Type	Method and Description
static TumblingDurationWindow	TumblingDurationWindow.of(BaseWindowedBolt.Duration windowLength)
static SlidingDurationWindow	SlidingDurationWindow.of(BaseWindowedBolt.Duration windowDuration, BaseWindowedBolt.Duration slidingDuration)