Package org.apache.flink.api.common.operators

Interface ProcessingTimeService.ProcessingTimeCallback

All Known Implementing Classes:

FileWriter, ProcTimeMiniBatchAssignerOperator, StreamingFileSinkHelper, TimestampsAndWatermarksOperator, WatermarkAssignerOperator

Enclosing interface:

ProcessingTimeService

@PublicEvolving
public static interface ProcessingTimeService.ProcessingTimeCallback

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

Method Summary

Modifier and Type	Method	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,
                      InterruptedException,
                      Exception

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

Parameters:

time - The time this callback was registered for.

Throws:

IOException

InterruptedException

Exception