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