Sink
and use
ProcessingTimeService
.@Deprecated @PublicEvolving public static interface Sink.ProcessingTimeService
Sink.ProcessingTimeService.ProcessingTimeCallback
when firing.Modifier and Type | Interface and Description |
---|---|
static interface |
Sink.ProcessingTimeService.ProcessingTimeCallback
Deprecated.
Please migrate to
Sink and use
ProcessingTimeService.ProcessingTimeCallback . |
Modifier and Type | Method and Description |
---|---|
long |
getCurrentProcessingTime()
Deprecated.
Returns the current processing time.
|
void |
registerProcessingTimer(long time,
Sink.ProcessingTimeService.ProcessingTimeCallback processingTimerCallback)
Deprecated.
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–2023 The Apache Software Foundation. All rights reserved.