Uses of Class
org.apache.storm.topology.base.BaseWindowedBolt.Count
-
Packages that use BaseWindowedBolt.Count Package Description org.apache.storm.bolt org.apache.storm.streams.windowing org.apache.storm.topology org.apache.storm.topology.base -
-
Uses of BaseWindowedBolt.Count in org.apache.storm.bolt
Methods in org.apache.storm.bolt with parameters of type BaseWindowedBolt.Count Modifier and Type Method Description JoinBoltJoinBolt. withTumblingWindow(BaseWindowedBolt.Count count)JoinBoltJoinBolt. withWindow(BaseWindowedBolt.Count windowLength)JoinBoltJoinBolt. withWindow(BaseWindowedBolt.Count windowLength, BaseWindowedBolt.Count slidingInterval)JoinBoltJoinBolt. withWindow(BaseWindowedBolt.Count windowLength, BaseWindowedBolt.Duration slidingInterval)JoinBoltJoinBolt. withWindow(BaseWindowedBolt.Duration windowLength, BaseWindowedBolt.Count slidingInterval) -
Uses of BaseWindowedBolt.Count in org.apache.storm.streams.windowing
Methods in org.apache.storm.streams.windowing that return types with arguments of type BaseWindowedBolt.Count Modifier and Type Method Description static SlidingWindows<BaseWindowedBolt.Count,BaseWindowedBolt.Count>SlidingWindows. of(BaseWindowedBolt.Count windowLength, BaseWindowedBolt.Count slidingInterval)Count based sliding window configuration.static SlidingWindows<BaseWindowedBolt.Count,BaseWindowedBolt.Count>SlidingWindows. of(BaseWindowedBolt.Count windowLength, BaseWindowedBolt.Count slidingInterval)Count based sliding window configuration.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 TumblingWindows<BaseWindowedBolt.Count>TumblingWindows. of(BaseWindowedBolt.Count count)A count based tumbling window.Methods in org.apache.storm.streams.windowing with parameters of type BaseWindowedBolt.Count Modifier and Type Method Description static SlidingWindows<BaseWindowedBolt.Count,BaseWindowedBolt.Count>SlidingWindows. of(BaseWindowedBolt.Count windowLength, BaseWindowedBolt.Count slidingInterval)Count based sliding window configuration.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 TumblingWindows<BaseWindowedBolt.Count>TumblingWindows. of(BaseWindowedBolt.Count count)A count based tumbling window. -
Uses of BaseWindowedBolt.Count in org.apache.storm.topology
Methods in org.apache.storm.topology with parameters of type BaseWindowedBolt.Count 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.Count in org.apache.storm.topology.base
Methods in org.apache.storm.topology.base that return BaseWindowedBolt.Count Modifier and Type Method Description static BaseWindowedBolt.CountBaseWindowedBolt.Count. of(int value)Returns aBaseWindowedBolt.Countof given value.Methods in org.apache.storm.topology.base with parameters of type BaseWindowedBolt.Count Modifier and Type Method Description BaseStatefulWindowedBolt<T>BaseStatefulWindowedBolt. withTumblingWindow(BaseWindowedBolt.Count count)A count based tumbling window.BaseWindowedBoltBaseWindowedBolt. withTumblingWindow(BaseWindowedBolt.Count count)A count based tumbling window.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, BaseWindowedBolt.Count slidingInterval)Time duration and count based sliding window configuration.BaseWindowedBoltBaseWindowedBolt. withWindow(BaseWindowedBolt.Count windowLength)A tuple count based window that slides with every incoming tuple.BaseWindowedBoltBaseWindowedBolt. withWindow(BaseWindowedBolt.Count windowLength, BaseWindowedBolt.Count slidingInterval)Tuple count 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, BaseWindowedBolt.Count slidingInterval)Time duration and count based sliding window configuration.
-