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 JoinBolt
JoinBolt. withTumblingWindow(BaseWindowedBolt.Count count)
JoinBolt
JoinBolt. withWindow(BaseWindowedBolt.Count windowLength)
JoinBolt
JoinBolt. withWindow(BaseWindowedBolt.Count windowLength, BaseWindowedBolt.Count slidingInterval)
JoinBolt
JoinBolt. withWindow(BaseWindowedBolt.Count windowLength, BaseWindowedBolt.Duration slidingInterval)
JoinBolt
JoinBolt. 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 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.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.Count
BaseWindowedBolt.Count. of(int value)
Returns aBaseWindowedBolt.Count
of 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.BaseWindowedBolt
BaseWindowedBolt. 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.BaseWindowedBolt
BaseWindowedBolt. withWindow(BaseWindowedBolt.Count windowLength)
A tuple count based window that slides with every incoming tuple.BaseWindowedBolt
BaseWindowedBolt. withWindow(BaseWindowedBolt.Count windowLength, BaseWindowedBolt.Count slidingInterval)
Tuple count based sliding window configuration.BaseWindowedBolt
BaseWindowedBolt. withWindow(BaseWindowedBolt.Count windowLength, BaseWindowedBolt.Duration slidingInterval)
Tuple count and time duration based sliding window configuration.BaseWindowedBolt
BaseWindowedBolt. withWindow(BaseWindowedBolt.Duration windowLength, BaseWindowedBolt.Count slidingInterval)
Time duration and count based sliding window configuration.
-