paimon icon indicating copy to clipboard operation
paimon copied to clipboard

[feature][flink] introduce RecordAttributesProcessor for write operators

Open yunfengzhou-hub opened this issue 1 year ago • 1 comments

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.

yunfengzhou-hub avatar Jul 22 '24 06:07 yunfengzhou-hub

Hi @JingsongLi could you please take a look at this PR?

yunfengzhou-hub avatar Jul 23 '24 09:07 yunfengzhou-hub