paimon
paimon copied to clipboard
[feature][flink] introduce RecordAttributesProcessor for write operators
Purpose
This PR introduces RecordAttributesProcessor for write operators, providing the ability to handle record attributes during constructing sink operators.
Tests
WriteOperatorTest.testProcessRecordAttributes is introduced to verify the correctness of this PR.
API and Format
This change does not affect API or storage format.
Documentation
This change does not introduce changes that require a document.
Hi @JingsongLi could you please take a look at this PR?