This is an automated email from the ASF dual-hosted git repository.
yihua pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new 0cc89702140 [MINOR] Removing unused function convertMetadataToRecords
(#11822)
0cc89702140 is described below
commit 0cc8970214013c616d358e27b2378893a23d0379
Author: Bibhu <[email protected]>
AuthorDate: Sun Sep 1 10:38:15 2024 +0530
[MINOR] Removing unused function convertMetadataToRecords (#11822)
Co-authored-by: Bibhu Pala <[email protected]>
---
.../apache/hudi/metadata/HoodieTableMetadataUtil.java | 16 ----------------
1 file changed, 16 deletions(-)
diff --git
a/hudi-common/src/main/java/org/apache/hudi/metadata/HoodieTableMetadataUtil.java
b/hudi-common/src/main/java/org/apache/hudi/metadata/HoodieTableMetadataUtil.java
index 015dd368081..84ea907a092 100644
---
a/hudi-common/src/main/java/org/apache/hudi/metadata/HoodieTableMetadataUtil.java
+++
b/hudi-common/src/main/java/org/apache/hudi/metadata/HoodieTableMetadataUtil.java
@@ -732,22 +732,6 @@ public class HoodieTableMetadataUtil {
});
}
- /**
- * Convert rollback action metadata to metadata table records.
- * <p>
- * We only need to handle FILES partition here as HUDI rollbacks on MOR
table may end up adding a new log file. All other partitions
- * are handled by actual rollback of the deltacommit which added records to
those partitions.
- */
- public static Map<MetadataPartitionType, HoodieData<HoodieRecord>>
convertMetadataToRecords(
- HoodieEngineContext engineContext, HoodieTableMetaClient
dataTableMetaClient, HoodieRollbackMetadata rollbackMetadata, String
instantTime) {
-
- List<HoodieRecord> filesPartitionRecords =
convertMetadataToRollbackRecords(rollbackMetadata, instantTime,
dataTableMetaClient);
- final HoodieData<HoodieRecord> rollbackRecordsRDD =
filesPartitionRecords.isEmpty() ? engineContext.emptyHoodieData()
- : engineContext.parallelize(filesPartitionRecords,
filesPartitionRecords.size());
-
- return Collections.singletonMap(MetadataPartitionType.FILES,
rollbackRecordsRDD);
- }
-
private static void reAddLogFilesFromRollbackPlan(HoodieTableMetaClient
dataTableMetaClient, String instantTime,
Map<String, Map<String,
Long>> partitionToFilesMap) {
HoodieInstant rollbackInstant = new
HoodieInstant(HoodieInstant.State.REQUESTED, HoodieTimeline.ROLLBACK_ACTION,
instantTime);