public static interface Sink.ProcessingTimeService
Sink.ProcessingTimeService.ProcessingTimeCallback
when firing.Modifier and Type | Interface and Description |
---|---|
static interface |
Sink.ProcessingTimeService.ProcessingTimeCallback
A callback that can be registered via
registerProcessingTimer(long,
ProcessingTimeCallback) . |
Modifier and Type | Method and Description |
---|---|
long |
getCurrentProcessingTime()
Returns the current processing time.
|
void |
registerProcessingTimer(long time,
Sink.ProcessingTimeService.ProcessingTimeCallback processingTimerCallback)
Invokes the given callback at the given timestamp.
|
long getCurrentProcessingTime()
void registerProcessingTimer(long time, Sink.ProcessingTimeService.ProcessingTimeCallback processingTimerCallback)
time
- Time when the callback is invoked atprocessingTimerCallback
- The callback to be invoked.Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.