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 © 2022 The Apache Software Foundation. All rights reserved.