@PublicEvolving public interface PunctuatedWatermarkAssignerProvider extends SupportsWatermarkPushDown.WatermarkProvider
AssignerWithPunctuatedWatermarks
instance as a runtime implementation for
generating watermarks in ScanTableSource
.Modifier and Type | Method and Description |
---|---|
AssignerWithPunctuatedWatermarks<RowData> |
getPunctuatedWatermarkAssigner() |
AssignerWithPunctuatedWatermarks<RowData> getPunctuatedWatermarkAssigner()
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.