polyzos opened a new issue, #1731: URL: https://github.com/apache/fluss/issues/1731
### Search before asking - [x] I searched in the [issues](https://github.com/apache/fluss/issues) and found nothing similar. ### Description #1404 introduced a RowConverterUtils, which is exposed to the end user. However, the conversion from POJO to InternalRow should happen automatically under the API, because we already know the schema of the table. We can introduce a `SpecificUpsertWriter<T> extends UpsertWriter` which provides additional POJO-type-based APIs `upsert(T record)` and `delete(T record)`. The `SpecificUpsertWriter<T>` can be got from `Upsert#createWriter(Class<T> specifcPojo)`. When the framework creates a `SpecificUpsertWriter`, it first checks the POJO type (whether it's a valid POJO type, and whether it can convert from/to InternalRow). We can introduce similar APIs for `Append` and `Scan`. ### Willingness to contribute - [x] I'm willing to submit a PR! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
