org.apache.flink.streaming.connectors.kafka.internals

Class SourceContextWatermarkOutputAdapter<T>

java.lang.Object

org.apache.flink.streaming.connectors.kafka.internals.SourceContextWatermarkOutputAdapter<T>

All Implemented Interfaces:

WatermarkOutput

public class SourceContextWatermarkOutputAdapter<T>
extends Object
implements WatermarkOutput

A WatermarkOutput that forwards calls to a SourceFunction.SourceContext.

Constructor Summary

Constructors

Constructor and Description
SourceContextWatermarkOutputAdapter(SourceFunction.SourceContext<T> sourceContext)

Method Summary

Modifier and Type	Method and Description
void	emitWatermark(Watermark watermark) Emits the given watermark.
void	markIdle() Marks this output as idle, meaning that downstream operations do not wait for watermarks from this output.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SourceContextWatermarkOutputAdapter

public SourceContextWatermarkOutputAdapter(SourceFunction.SourceContext<T> sourceContext)

Method Detail

emitWatermark

public void emitWatermark(Watermark watermark)

Description copied from interface: WatermarkOutput

Emits the given watermark.

Emitting a watermark also implicitly marks the stream as active, ending previously marked idleness.

Specified by:

emitWatermark in interface WatermarkOutput

markIdle

public void markIdle()

Description copied from interface: WatermarkOutput

Marks this output as idle, meaning that downstream operations do not wait for watermarks from this output.

An output becomes active again as soon as the next watermark is emitted.

Specified by:

markIdle in interface WatermarkOutput