public static interface ProcessFunction.Context
ProcessFunction.processElement(Object, Context, Collector)
or ProcessFunction.onTimer(long, OnTimerContext, Collector)
.Modifier and Type | Method and Description |
---|---|
TimerService |
timerService()
A
TimerService for querying time and registering timers. |
Long |
timestamp()
Timestamp of the element currently being processed or timestamp of a firing timer.
|
Long timestamp()
This might be null
, for example if the time characteristic of your program
is set to TimeCharacteristic.ProcessingTime
.
TimerService timerService()
TimerService
for querying time and registering timers.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.