Package org.apache.flink.api.common.eventtime

Class WatermarkOutputMultiplexer.NoOpWatermarkUpdateListener

java.lang.Object

org.apache.flink.api.common.eventtime.WatermarkOutputMultiplexer.NoOpWatermarkUpdateListener

All Implemented Interfaces:

WatermarkOutputMultiplexer.WatermarkUpdateListener

Enclosing class:

WatermarkOutputMultiplexer

@Internal
public static class WatermarkOutputMultiplexer.NoOpWatermarkUpdateListener
extends Object
implements WatermarkOutputMultiplexer.WatermarkUpdateListener

A No-op implementation of WatermarkOutputMultiplexer.WatermarkUpdateListener.

Constructor Summary

Constructors

Constructor	Description
NoOpWatermarkUpdateListener()

Method Summary

Modifier and Type	Method	Description
void	onIdleUpdate(boolean idle)	Called when the idle state changes.
void	onWatermarkUpdate(long watermark)	Called when the watermark increases.

Methods inherited from class java.lang.Object

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

Constructor Detail

NoOpWatermarkUpdateListener

public NoOpWatermarkUpdateListener()

Method Detail

onWatermarkUpdate

public void onWatermarkUpdate(long watermark)

Description copied from interface: WatermarkOutputMultiplexer.WatermarkUpdateListener

Called when the watermark increases.

Specified by:

onWatermarkUpdate in interface WatermarkOutputMultiplexer.WatermarkUpdateListener

onIdleUpdate

public void onIdleUpdate(boolean idle)

Description copied from interface: WatermarkOutputMultiplexer.WatermarkUpdateListener

Called when the idle state changes.

Specified by:

onIdleUpdate in interface WatermarkOutputMultiplexer.WatermarkUpdateListener