@PublicEvolving public abstract class PunctuatedWatermarkAssigner extends WatermarkStrategy
Constructor and Description |
---|
PunctuatedWatermarkAssigner() |
Modifier and Type | Method and Description |
---|---|
abstract Watermark |
getWatermark(Row row,
long timestamp)
Returns the watermark for the current row or null if no watermark should be generated.
|
toProperties
public abstract Watermark getWatermark(Row row, long timestamp)
row
- The current row.timestamp
- The value of the timestamp attribute for the row.Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.