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)
