Sink.ProcessingTimeService (Flink : Core 1.20.2-cp1 API)

Enclosing interface:

Sink<InputT,CommT,WriterStateT,GlobalCommT>
```
@Deprecated
@PublicEvolving
public static interface Sink.ProcessingTimeService
```
Deprecated.
Please migrate to Sink and use ProcessingTimeService.

A service that allows to get the current processing time and register timers that will execute the given Sink.ProcessingTimeService.ProcessingTimeCallback when firing.

Nested Class Summary

Nested Classes
Modifier and Type	Interface	Description
`static interface`	`Sink.ProcessingTimeService.ProcessingTimeCallback`	Deprecated. Please migrate to `Sink` and use `ProcessingTimeService.ProcessingTimeCallback`.

Method Summary

All Methods Instance Methods Abstract Methods Deprecated Methods
Modifier and Type	Method	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.

- Method Detail
  - getCurrentProcessingTime
```
long getCurrentProcessingTime()
```
    Deprecated.
    
    Returns the current processing time.
  - registerProcessingTimer
```
void registerProcessingTimer(long time,
                             Sink.ProcessingTimeService.ProcessingTimeCallback processingTimerCallback)
```
    Deprecated.
    
    Invokes the given callback at the given timestamp.
    
    Parameters:
    
    time - Time when the callback is invoked at
    
    processingTimerCallback - The callback to be invoked.