Sink
and use
ProcessingTimeService.ProcessingTimeCallback
.@Deprecated @PublicEvolving public static interface Sink.ProcessingTimeService.ProcessingTimeCallback
Sink.ProcessingTimeService.registerProcessingTimer(long,
ProcessingTimeCallback)
.Modifier and Type | Method and Description |
---|---|
void |
onProcessingTime(long time)
Deprecated.
This method is invoked with the time which the callback register for.
|
void onProcessingTime(long time) throws IOException, InterruptedException
time
- The time this callback was registered for.IOException
InterruptedException
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.