WatermarkGeneratorSupplier (Flink : Core 1.20.2-cp1 API)

All Superinterfaces:

Serializable

All Known Subinterfaces:

WatermarkStrategy<T>

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
```
@PublicEvolving
@FunctionalInterface
public interface WatermarkGeneratorSupplier<T>
extends Serializable
```
A supplier for WatermarkGenerators. The supplier pattern is used to avoid having to make WatermarkGenerator Serializable for use in API methods.
This interface is Serializable because the supplier may be shipped to workers during distributed execution.

Nested Class Summary

Nested Classes
Modifier and Type Interface Description

static interface WatermarkGeneratorSupplier.Context
Additional information available to createWatermarkGenerator(Context).

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`WatermarkGenerator<T>`	`createWatermarkGenerator(WatermarkGeneratorSupplier.Context context)`	Instantiates a `WatermarkGenerator`.

Method Detail

createWatermarkGenerator

WatermarkGenerator<T> createWatermarkGenerator(WatermarkGeneratorSupplier.Context context)

Instantiates a WatermarkGenerator.