[
https://issues.apache.org/jira/browse/FLINK-37473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky updated FLINK-37473:
---------------------------------
Fix Version/s: (was: kudu-2.0.0)
> 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
> Priority: Major
>
> 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)
