[
https://issues.apache.org/jira/browse/FLINK-37011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17912775#comment-17912775
]
ChaomingZhang commented on FLINK-37011:
---------------------------------------
[~Leonard] Please assign to me.
> 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
> Priority: Major
> Labels: pull-request-available
>
>
> {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)
