Package org.apache.flink.streaming.runtime.operators.util

Class AssignerWithPeriodicWatermarksAdapter<T>

java.lang.Object

org.apache.flink.streaming.runtime.operators.util.AssignerWithPeriodicWatermarksAdapter<T>

All Implemented Interfaces:

org.apache.flink.api.common.eventtime.WatermarkGenerator<T>

@Internal
public final class AssignerWithPeriodicWatermarksAdapter<T>
extends Object
implements org.apache.flink.api.common.eventtime.WatermarkGenerator<T>

An adapter that wraps a AssignerWithPeriodicWatermarks into a WatermarkGenerator.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AssignerWithPeriodicWatermarksAdapter.Strategy<T>	A WatermarkStrategy that returns an AssignerWithPeriodicWatermarks wrapped as a WatermarkGenerator.

Constructor Summary

Constructors

Constructor	Description
AssignerWithPeriodicWatermarksAdapter(AssignerWithPeriodicWatermarks<T> wms)

Method Summary

Modifier and Type	Method	Description
void	onEvent(T event, long eventTimestamp, org.apache.flink.api.common.eventtime.WatermarkOutput output)
void	onPeriodicEmit(org.apache.flink.api.common.eventtime.WatermarkOutput output)

Methods inherited from class java.lang.Object

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

Constructor Detail

AssignerWithPeriodicWatermarksAdapter

public AssignerWithPeriodicWatermarksAdapter(AssignerWithPeriodicWatermarks<T> wms)

Method Detail

onEvent

public void onEvent(T event,
                    long eventTimestamp,
                    org.apache.flink.api.common.eventtime.WatermarkOutput output)

Specified by:

onEvent in interface org.apache.flink.api.common.eventtime.WatermarkGenerator<T>

onPeriodicEmit

public void onPeriodicEmit(org.apache.flink.api.common.eventtime.WatermarkOutput output)

Specified by:

onPeriodicEmit in interface org.apache.flink.api.common.eventtime.WatermarkGenerator<T>