YuweiXiao commented on code in PR #4441:
URL: https://github.com/apache/hudi/pull/4441#discussion_r857055303
##########
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/BulkInsertPartitioner.java:
##########
@@ -38,4 +44,25 @@
* @return {@code true} if the records within a partition are sorted; {@code
false} otherwise.
*/
boolean arePartitionRecordsSorted();
+
+ /**
+ * Return file group id prefix for the given data partition.
+ * By defauult, return a new file group id prefix, so that incoming records
will route to a fresh new file group
+ * @param partitionId data partition
+ * @return
+ */
+ default String getFileIdPfx(int partitionId) {
+ return FSUtils.createNewFileIdPfx();
+ }
+
+ /**
+ * Return write handle factory for the given partition.
+ * By default, return CreateHandleFactory which will always write to a new
file group
Review Comment:
Thanks! Fixed.
--
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]
