Uses of Interface
org.apache.storm.windowing.TimestampExtractor
-
Packages that use TimestampExtractor Package Description org.apache.storm.bolt org.apache.storm.topology org.apache.storm.topology.base -
-
Uses of TimestampExtractor in org.apache.storm.bolt
Methods in org.apache.storm.bolt with parameters of type TimestampExtractor Modifier and Type Method Description JoinBolt
JoinBolt. withTimestampExtractor(TimestampExtractor timestampExtractor)
-
Uses of TimestampExtractor in org.apache.storm.topology
Classes in org.apache.storm.topology that implement TimestampExtractor Modifier and Type Class Description class
TupleFieldTimestampExtractor
ATimestampExtractor
that extracts timestamp from a specific field in the tuple.Methods in org.apache.storm.topology that return TimestampExtractor Modifier and Type Method Description TimestampExtractor
IWindowedBolt. getTimestampExtractor()
Return aTimestampExtractor
for extracting timestamps from a tuple for event time based processing, or null for processing time. -
Uses of TimestampExtractor in org.apache.storm.topology.base
Fields in org.apache.storm.topology.base declared as TimestampExtractor Modifier and Type Field Description protected TimestampExtractor
BaseWindowedBolt. timestampExtractor
Methods in org.apache.storm.topology.base that return TimestampExtractor Modifier and Type Method Description TimestampExtractor
BaseWindowedBolt. getTimestampExtractor()
Methods in org.apache.storm.topology.base with parameters of type TimestampExtractor Modifier and Type Method Description BaseStatefulWindowedBolt<T>
BaseStatefulWindowedBolt. withTimestampExtractor(TimestampExtractor timestampExtractor)
Specify the timestamp extractor implementation.BaseWindowedBolt
BaseWindowedBolt. withTimestampExtractor(TimestampExtractor timestampExtractor)
Specify the timestamp extractor implementation.
-