Marton Greber created FLINK-37473:
-------------------------------------
Summary: Fill in RowKind.DELETE in RowResultRowConverter if
possible
Key: FLINK-37473
URL: https://issues.apache.org/jira/browse/FLINK-37473
Project: Flink
Issue Type: Improvement
Components: Connectors / Kudu
Reporter: Marton Greber
Fix For: kudu-2.0.0
With the new Kudu Source API, if we are in continuous unbounded mode, the
connector uses Kudu's diffscan api to get incremental changes. In this diffscan
context we have to distinguish between 'data' rows and 'delete' rows.
Kudu exposes this information in the following RowResult functions:
RowResult.hasIsDeleted:
https://github.com/apache/kudu/blob/0b5b5da6d30d792915a2e22646a3f554783fd678/java/kudu-client/src/main/java/org/apache/kudu/client/RowResult.java#L504-L511
RowResult.isDeleted:
https://github.com/apache/kudu/blob/0b5b5da6d30d792915a2e22646a3f554783fd678/java/kudu-client/src/main/java/org/apache/kudu/client/RowResult.java#L513-L521
The task would be to fill in the Flink Row's kind as DELETE if the RowResult is
a deleted row (in RowResultRowConverter).
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
