kbuci commented on code in PR #18172:
URL: https://github.com/apache/hudi/pull/18172#discussion_r2886626359
##########
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/cluster/strategy/PartitionAwareClusteringPlanStrategy.java:
##########
@@ -102,15 +102,23 @@ protected Pair<Stream<HoodieClusteringGroup>, Boolean>
buildClusteringGroupsForP
}
if (!currentGroup.isEmpty()) {
- if (currentGroup.size() > 1 ||
writeConfig.shouldClusteringSingleGroup()) {
- int numOutputGroups = getNumberOfOutputFileGroups(totalSizeSoFar,
writeConfig.getClusteringTargetFileMaxBytes());
- log.info("Adding final clustering group " + totalSizeSoFar + " max
bytes: "
- + writeConfig.getClusteringMaxBytesInGroup() + " num input slices:
" + currentGroup.size() + " output groups: " + numOutputGroups);
- fileSliceGroups.add(Pair.of(currentGroup, numOutputGroups));
- }
+ int numOutputGroups = getNumberOfOutputFileGroups(totalSizeSoFar,
writeConfig.getClusteringTargetFileMaxBytes());
+ log.info("Adding final clustering group " + totalSizeSoFar + " max
bytes: "
+ + writeConfig.getClusteringMaxBytesInGroup() + " num input slices: "
+ currentGroup.size() + " output groups: " + numOutputGroups);
+ fileSliceGroups.add(Pair.of(currentGroup, numOutputGroups));
}
- return Pair.of(fileSliceGroups.stream().map(fileSliceGroup ->
+ return Pair.of(fileSliceGroups.stream().filter(fileSliceGroup -> {
+ if (fileSliceGroup.getLeft().size() > 1 || fileSliceGroup.getRight() > 1
|| writeConfig.shouldClusteringSingleGroup()) {
Review Comment:
Oh here were as selecting which clustering groups to "allow". So in order
for us to not remove a clustering group, one of the below conditions has to be
true
- There are multiple input files in the group (stitching together small
files)
- There are multiple output files in the group ("splitting" a large file)
- The user config specifies to allow clustering groups with a single file
group (either explicitly via that config or implicitly by providing sort
columns)
--
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]
