[
https://issues.apache.org/jira/browse/FLINK-37011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-37011.
--------------------------------
Resolution: Resolved
Resolved in master: 999258436595759556daecddd9c158899b3c60e8
> Improve get source field value by column name in PreTransformProcessor.
> -----------------------------------------------------------------------
>
> Key: FLINK-37011
> URL: https://issues.apache.org/jira/browse/FLINK-37011
> Project: Flink
> Issue Type: Improvement
> Components: Flink CDC
> Reporter: ChaomingZhang
> Assignee: ChaomingZhang
> Priority: Major
> Labels: pull-request-available
> Fix For: cdc-3.3.0
>
>
>
> {code:java}
> private Object getValueFromBinaryRecordData(
> String columnName,
> BinaryRecordData binaryRecordData,
> List<Column> columns,
> RecordData.FieldGetter[] fieldGetters) {
> for (int i = 0; i < columns.size(); i++) {
> if (columnName.equals(columns.get(i).getName())) {
> return DataTypeConverter.convert(
> fieldGetters[i].getFieldOrNull(binaryRecordData),
> columns.get(i).getType());
> }
> }
> return null;
> } {code}
> Use HashMap to reduce iteration cost.
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
