org.apache.flink.api.connector.sink

Interface Sink.ProcessingTimeService.ProcessingTimeCallback

All Known Implementing Classes:

FileWriter

Enclosing interface:

Sink.ProcessingTimeService

public static interface Sink.ProcessingTimeService.ProcessingTimeCallback

A callback that can be registered via Sink.ProcessingTimeService.registerProcessingTimer(long, ProcessingTimeCallback).

Method Summary

Modifier and Type	Method and Description
void	onProcessingTime(long time) This method is invoked with the time which the callback register for.

Method Detail

onProcessingTime

void onProcessingTime(long time)
               throws IOException

This method is invoked with the time which the callback register for.

Parameters:

time - The time this callback was registered for.

Throws:

IOException