Package | Description |
---|---|
org.apache.flink.table.connector.source.abilities |
Modifier and Type | Interface and Description |
---|---|
interface |
PeriodicWatermarkAssignerProvider
Provider of an
AssignerWithPeriodicWatermarks instance as a runtime implementation for
generating watermarks in ScanTableSource . |
interface |
PunctuatedWatermarkAssignerProvider
Provider of an
AssignerWithPunctuatedWatermarks instance as a runtime implementation for
generating watermarks in ScanTableSource . |
Modifier and Type | Method and Description |
---|---|
void |
SupportsWatermarkPushDown.applyWatermark(SupportsWatermarkPushDown.WatermarkProvider provider)
Provides actual runtime implementation for generating watermarks.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.