Package | Description |
---|---|
org.apache.storm.streams.windowing |
Modifier and Type | Method and Description |
---|---|
static TumblingWindows<BaseWindowedBolt.Count> |
TumblingWindows.of(BaseWindowedBolt.Count count)
A count based tumbling window.
|
static TumblingWindows<BaseWindowedBolt.Duration> |
TumblingWindows.of(BaseWindowedBolt.Duration duration)
A time duration based tumbling window.
|
TumblingWindows<L> |
TumblingWindows.withLag(BaseWindowedBolt.Duration duration)
Specify the maximum time lag of the tuple timestamp in milliseconds.
|
TumblingWindows<L> |
TumblingWindows.withLateTupleStream(String streamId)
Specify a stream id on which late tuples are going to be emitted.
|
TumblingWindows<L> |
TumblingWindows.withTimestampField(String fieldName)
The name of the field in the tuple that contains the timestamp when the event occurred as a long value.
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.