nsivabalan commented on code in PR #9311:
URL: https://github.com/apache/hudi/pull/9311#discussion_r1280015743
##########
hudi-common/src/main/java/org/apache/hudi/metadata/HoodieMetadataPayload.java:
##########
@@ -166,11 +166,15 @@ public class HoodieMetadataPayload implements
HoodieRecordPayload<HoodieMetadata
/**
* HoodieMetadata record index payload field ids
*/
- public static final String RECORD_INDEX_FIELD_PARTITION = "partition";
+ public static final String RECORD_INDEX_FIELD_PARTITION = "partitionName";
public static final String RECORD_INDEX_FIELD_FILEID_HIGH_BITS =
"fileIdHighBits";
public static final String RECORD_INDEX_FIELD_FILEID_LOW_BITS =
"fileIdLowBits";
public static final String RECORD_INDEX_FIELD_FILE_INDEX = "fileIndex";
public static final String RECORD_INDEX_FIELD_INSTANT_TIME = "instantTime";
+ public static final String RECORD_INDEX_FIELD_FILEID = "fileId";
+ public static final String RECORD_INDEX_FIELD_FILEID_ENCODING =
"fileIdEncoding";
+ public static final int RECORD_INDEX_FIELD_FILEID_ENCODING_UUID = 0;
+ public static final int RECORD_INDEX_FIELD_FILEID_ENCODING_RAW_STRING = 1;
Review Comment:
it is doable. every commit can switch.
for eg, we can do one write w/ kafka connect. and then do another write
using JavawriteClient directly. the internal config serves the purposes. it is
not a table config for this reason
--
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]
