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

Class WatermarkDeclarations.WatermarkDeclarationBuilder

java.lang.Object

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

Enclosing class:

WatermarkDeclarations

@Experimental
public static class WatermarkDeclarations.WatermarkDeclarationBuilder
extends Object

Builder class for WatermarkDeclarations.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	WatermarkDeclarations.WatermarkDeclarationBuilder.BoolWatermarkDeclarationBuilder
static class	WatermarkDeclarations.WatermarkDeclarationBuilder.LongWatermarkDeclarationBuilder

Field Summary

Fields

Modifier and Type	Field	Description
protected String	identifier

Method Summary

Modifier and Type	Method	Description
WatermarkDeclarations.WatermarkDeclarationBuilder.BoolWatermarkDeclarationBuilder	typeBool()
WatermarkDeclarations.WatermarkDeclarationBuilder.LongWatermarkDeclarationBuilder	typeLong()

Methods inherited from class java.lang.Object

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

Field Detail

identifier

protected final String identifier

Method Detail

typeLong

public WatermarkDeclarations.WatermarkDeclarationBuilder.LongWatermarkDeclarationBuilder typeLong()

typeBool

public WatermarkDeclarations.WatermarkDeclarationBuilder.BoolWatermarkDeclarationBuilder typeBool()