| Package | Description | 
|---|---|
| org.apache.storm.bolt | |
| org.apache.storm.streams.windowing | |
| org.apache.storm.topology | |
| org.apache.storm.topology.base | 
| Modifier and Type | Method and 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)  | 
| Modifier and Type | Method and Description | 
|---|---|
static TumblingWindows<BaseWindowedBolt.Count> | 
TumblingWindows.of(BaseWindowedBolt.Count count)
A count based tumbling window. 
 | 
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. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static TumblingWindows<BaseWindowedBolt.Count> | 
TumblingWindows.of(BaseWindowedBolt.Count count)
A count based tumbling window. 
 | 
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. 
 | 
| 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)  | 
| Modifier and Type | Method and Description | 
|---|---|
static BaseWindowedBolt.Count | 
BaseWindowedBolt.Count.of(int value)
Returns a  
BaseWindowedBolt.Count of given value. | 
| Modifier and Type | Method and Description | 
|---|---|
BaseWindowedBolt | 
BaseWindowedBolt.withTumblingWindow(BaseWindowedBolt.Count count)
A count based tumbling window. 
 | 
BaseStatefulWindowedBolt<T> | 
BaseStatefulWindowedBolt.withTumblingWindow(BaseWindowedBolt.Count count)
A count based tumbling window. 
 | 
BaseWindowedBolt | 
BaseWindowedBolt.withWindow(BaseWindowedBolt.Count windowLength)
A tuple count based window that slides with every incoming tuple. 
 | 
BaseStatefulWindowedBolt<T> | 
BaseStatefulWindowedBolt.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. 
 | 
BaseStatefulWindowedBolt<T> | 
BaseStatefulWindowedBolt.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. 
 | 
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,
          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. 
 | 
Copyright © 2019 The Apache Software Foundation. All rights reserved.