Uses of Class
org.apache.storm.topology.base.BaseWindowedBolt.Duration
-
-
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 Description BaseWindowedBoltJoinBolt. withLag(BaseWindowedBolt.Duration duration)JoinBoltJoinBolt. withTumblingWindow(BaseWindowedBolt.Duration duration)BaseWindowedBoltJoinBolt. withWatermarkInterval(BaseWindowedBolt.Duration interval)JoinBoltJoinBolt. withWindow(BaseWindowedBolt.Count windowLength, BaseWindowedBolt.Duration slidingInterval)JoinBoltJoinBolt. withWindow(BaseWindowedBolt.Duration windowLength)JoinBoltJoinBolt. withWindow(BaseWindowedBolt.Duration windowLength, BaseWindowedBolt.Count slidingInterval)JoinBoltJoinBolt. 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 Description protected BaseWindowedBolt.DurationBaseWindow. lagMethods in org.apache.storm.streams.windowing that return BaseWindowedBolt.Duration Modifier and Type Method Description BaseWindowedBolt.DurationBaseWindow. getLag()BaseWindowedBolt.DurationWindow. 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 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 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.static TumblingWindows<BaseWindowedBolt.Duration>TumblingWindows. of(BaseWindowedBolt.Duration duration)A time duration based tumbling window.Methods in org.apache.storm.streams.windowing with parameters of type BaseWindowedBolt.Duration Modifier and Type Method 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 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 TumblingWindows<BaseWindowedBolt.Duration>TumblingWindows. of(BaseWindowedBolt.Duration duration)A time duration based tumbling window.SlidingWindows<L,I>SlidingWindows. withLag(BaseWindowedBolt.Duration duration)Specify the maximum time lag of the tuple timestamp in milliseconds.TumblingWindows<L>TumblingWindows. 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 Description protected voidPersistentWindowedBoltExecutor. validate(Map<String,Object> topoConf, BaseWindowedBolt.Count windowLengthCount, BaseWindowedBolt.Duration windowLengthDuration, BaseWindowedBolt.Count slidingIntervalCount, BaseWindowedBolt.Duration slidingIntervalDuration)protected voidWindowedBoltExecutor. 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 Description static BaseWindowedBolt.DurationBaseWindowedBolt.Duration. days(int days)Returns aBaseWindowedBolt.Durationcorresponding to the the given value in days.static BaseWindowedBolt.DurationBaseWindowedBolt.Duration. hours(int hours)Returns aBaseWindowedBolt.Durationcorresponding to the the given value in hours.static BaseWindowedBolt.DurationBaseWindowedBolt.Duration. minutes(int minutes)Returns aBaseWindowedBolt.Durationcorresponding to the the given value in minutes.static BaseWindowedBolt.DurationBaseWindowedBolt.Duration. of(int milliseconds)Returns aBaseWindowedBolt.Durationcorresponding to the the given value in milli seconds.static BaseWindowedBolt.DurationBaseWindowedBolt.Duration. seconds(int seconds)Returns aBaseWindowedBolt.Durationcorresponding to the the given value in seconds.Methods in org.apache.storm.topology.base with parameters of type BaseWindowedBolt.Duration Modifier and Type Method Description BaseStatefulWindowedBolt<T>BaseStatefulWindowedBolt. withLag(BaseWindowedBolt.Duration duration)Specify the maximum time lag of the tuple timestamp in milliseconds.BaseWindowedBoltBaseWindowedBolt. withLag(BaseWindowedBolt.Duration duration)Specify the maximum time lag of the tuple timestamp in milliseconds.BaseStatefulWindowedBolt<T>BaseStatefulWindowedBolt. withTumblingWindow(BaseWindowedBolt.Duration duration)A time duration based tumbling window.BaseWindowedBoltBaseWindowedBolt. withTumblingWindow(BaseWindowedBolt.Duration duration)A time duration based tumbling window.BaseStatefulWindowedBolt<T>BaseStatefulWindowedBolt. withWatermarkInterval(BaseWindowedBolt.Duration interval)Specify the watermark event generation interval.BaseWindowedBoltBaseWindowedBolt. withWatermarkInterval(BaseWindowedBolt.Duration interval)Specify the watermark event generation interval.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.BaseWindowedBoltBaseWindowedBolt. withWindow(BaseWindowedBolt.Count windowLength, BaseWindowedBolt.Duration slidingInterval)Tuple count and time duration based sliding window configuration.BaseWindowedBoltBaseWindowedBolt. withWindow(BaseWindowedBolt.Duration windowLength)A time duration based window that slides with every incoming tuple.BaseWindowedBoltBaseWindowedBolt. withWindow(BaseWindowedBolt.Duration windowLength, BaseWindowedBolt.Count slidingInterval)Time duration and count based sliding window configuration.BaseWindowedBoltBaseWindowedBolt. 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 Description StreamStream. 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 ofslidingIntervaland completes a window atwindowDuration.StreamStream. 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 ofwindowDuration. -
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 Description static SlidingDurationWindowSlidingDurationWindow. of(BaseWindowedBolt.Duration windowDuration, BaseWindowedBolt.Duration slidingDuration)static TumblingDurationWindowTumblingDurationWindow. of(BaseWindowedBolt.Duration windowLength)
-