Package org.apache.flink.table.runtime.operators.misc
-
Class Summary Class Description DropUpdateBeforeFunction A function drops only rows withRowKind.UPDATE_BEFOREchangelog kind.
| Class | Description |
|---|---|
| DropUpdateBeforeFunction |
A function drops only rows with
RowKind.UPDATE_BEFORE changelog kind. |