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);

Reply via email to