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