Package | Description |
---|---|
org.apache.storm.bolt | |
org.apache.storm.topology | |
org.apache.storm.topology.base |
Modifier and Type | Method and Description |
---|---|
JoinBolt |
JoinBolt.withTimestampExtractor(TimestampExtractor timestampExtractor) |
Modifier and Type | Class and Description |
---|---|
class |
TupleFieldTimestampExtractor
A
TimestampExtractor that extracts timestamp from a specific field in the tuple. |
Modifier and Type | Method and Description |
---|---|
TimestampExtractor |
IWindowedBolt.getTimestampExtractor()
Return a
TimestampExtractor for extracting timestamps from a tuple for event time based processing, or null for processing time. |
Modifier and Type | Field and Description |
---|---|
protected TimestampExtractor |
BaseWindowedBolt.timestampExtractor |
Modifier and Type | Method and Description |
---|---|
TimestampExtractor |
BaseWindowedBolt.getTimestampExtractor() |
Modifier and Type | Method and Description |
---|---|
BaseWindowedBolt |
BaseWindowedBolt.withTimestampExtractor(TimestampExtractor timestampExtractor)
Specify the timestamp extractor implementation.
|
BaseStatefulWindowedBolt<T> |
BaseStatefulWindowedBolt.withTimestampExtractor(TimestampExtractor timestampExtractor)
Specify the timestamp extractor implementation.
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.