Package org.apache.flink.table.connector
Interface RowLevelModificationScanContext
-
@PublicEvolving public interface RowLevelModificationScanContext
The context is intended to provide the relevant table scan information needed by the sink to perform row-level update/delete. It'll be generated by a table source that implementsSupportsRowLevelModificationScan
, and then passed to a sink which implementsSupportsRowLevelUpdate
orSupportsRowLevelDelete
for executing UPDATE/DELETE statement during compilation phase.This mechanism enables the coordination between the table sources and the table sink which is to be updated/deleted.
Connectors can implement this interface to provide custom information.