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 SlidingWindows<BaseWindowedBolt.Duration,BaseWindowedBolt.Duration> |
SlidingWindows.of(BaseWindowedBolt.Duration windowLength,
BaseWindowedBolt.Duration slidingInterval) |
Time duration based sliding window configuration.
|
SlidingWindows<L,I> |
SlidingWindows.withLag(BaseWindowedBolt.Duration duration) |
Specify the maximum time lag of the tuple timestamp in milliseconds.
|
SlidingWindows<L,I> |
SlidingWindows.withLateTupleStream(String streamId) |
Specify a stream id on which late tuples are going to be emitted.
|
SlidingWindows<L,I> |
SlidingWindows.withTimestampField(String fieldName) |
The name of the field in the tuple that contains the timestamp when the event occurred as a long value.
|