org.apache.flink.streaming.runtime.streamstatus

Interface StatusWatermarkValve.ValveOutputHandler

Enclosing class:

StatusWatermarkValve

public static interface StatusWatermarkValve.ValveOutputHandler

Usages of StatusWatermarkValve should implement a ValveOutputHandler to handle watermark and stream status outputs from the valve.

Method Summary

Modifier and Type	Method and Description
void	handleStreamStatus(StreamStatus streamStatus)
void	handleWatermark(Watermark watermark)

Method Detail

handleWatermark

void handleWatermark(Watermark watermark)

handleStreamStatus

void handleStreamStatus(StreamStatus streamStatus)