Package org.apache.flink.api.common.watermark

Class WatermarkDeclarations

java.lang.Object

org.apache.flink.api.common.watermark.WatermarkDeclarations

@Experimental
public class WatermarkDeclarations
extends Object

The Utils class is used to create WatermarkDeclaration.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	WatermarkDeclarations.WatermarkDeclarationBuilder	Builder class for WatermarkDeclarations.

Constructor Summary

Constructors

Constructor	Description
WatermarkDeclarations()

Method Summary

Modifier and Type	Method	Description
static WatermarkDeclarations.WatermarkDeclarationBuilder	newBuilder(String identifier)

Methods inherited from class java.lang.Object

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

Constructor Detail

WatermarkDeclarations

public WatermarkDeclarations()

Method Detail

newBuilder

public static WatermarkDeclarations.WatermarkDeclarationBuilder newBuilder(String identifier)