org.apache.flink.streaming.runtime.tasks

Interface WatermarkGaugeExposingOutput<T>

Type Parameters:

T - The type of the elements that can be emitted.

All Superinterfaces:

AutoCloseable, Closeable, Collector<T>, Output<T>

All Known Subinterfaces:

OutputWithChainingCheck<OUT>

All Known Implementing Classes:

CountingOutput, FinishedOnRestoreMainOperatorOutput, RecordWriterOutput

public interface WatermarkGaugeExposingOutput<T>
extends Output<T>, Closeable

An Output that measures the last emitted watermark with a WatermarkGauge.

Method Summary

Modifier and Type	Method and Description
Gauge<Long>	getWatermarkGauge()

Methods inherited from interface org.apache.flink.streaming.api.operators.Output

collect, emitLatencyMarker, emitRecordAttributes, emitWatermark, emitWatermarkStatus

Methods inherited from interface org.apache.flink.util.Collector

close, collect

Methods inherited from interface java.io.Closeable

close

Method Detail

getWatermarkGauge

Gauge<Long> getWatermarkGauge()