[jira] [Created] (FLINK-37011) Improve get source field value by column name in PreTransformProcessor.

["ChaomingZhang (Jira)" <ji...@apache.org>]

ChaomingZhang created FLINK-37011:
-------------------------------------

             Summary: 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


 
{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)