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

Class AssignerWithPunctuatedWatermarksAdapter<T>

java.lang.Object

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

All Implemented Interfaces:

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

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

An adapter that wraps a AssignerWithPunctuatedWatermarks into a WatermarkGenerator.

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

Constructor	Description
AssignerWithPunctuatedWatermarksAdapter(AssignerWithPunctuatedWatermarks<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

AssignerWithPunctuatedWatermarksAdapter

public AssignerWithPunctuatedWatermarksAdapter(AssignerWithPunctuatedWatermarks<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>