[flink] Support updating row type to another row type in Flink

apache / paimon

Apache Paimon is a lake format that enables building a Realtime Lakehouse Architecture with Flink and Spark for both streaming and batch operations.

https://paimon.apache.org/

Apache License 2.0

2.43k stars 955 forks source link

[flink] Support updating row type to another row type in Flink #4499

Closed tsreaper closed 1 week ago

tsreaper commented 1 week ago

Purpose

Unlike Spark, Flink does not support directly updating a nested column. So we support updating a whole row type to another row type in Flink to implement this feature.

Tests

Unit tests and IT cases.

API and Format

No format changes.

Documentation

Document will be added later.