danny0405 commented on code in PR #13860:
URL: https://github.com/apache/hudi/pull/13860#discussion_r2350438239
##########
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieAvroIndexedRecord.java:
##########
@@ -185,9 +188,17 @@ public HoodieRecord joinWith(HoodieRecord other, Schema
targetSchema) {
}
@Override
- public HoodieRecord prependMetaFields(Schema recordSchema, Schema
targetSchema, MetadataValues metadataValues, Properties props) {
+ public HoodieRecord prependMetaFields(Schema recordSchema, Schema
targetSchema, MetadataValues metadataValues, Properties props,
+ boolean hasOperationMetaField) {
decodeRecord(recordSchema);
- GenericRecord newAvroRecord =
HoodieAvroUtils.rewriteRecordWithNewSchema(data, targetSchema);
+ List<String> metaFields = hasOperationMetaField ?
HoodieRecord.HOODIE_META_COLUMNS_WITH_OPERATION_LIST :
HoodieRecord.HOODIE_META_COLUMNS;
Review Comment:
Because the field is already in the schema, so that we can keep the API
clean, checking the 6th field name is also very efficient even if it is
row-level.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
