(hudi) branch master updated: [HUDI-7799] Optimize the access modifier of AbstractHoodieLogRecordReader#processNextRecord (#11308)

[danny0405]

This is an automated email from the ASF dual-hosted git repository.

danny0405 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 e80d50065cc [HUDI-7799] Optimize the access modifier of 
AbstractHoodieLogRecordReader#processNextRecord (#11308)
e80d50065cc is described below

commit e80d50065ccf5c9922be2bfd06bc1952fefac330
Author: usberkeley <150880684+usberke...@users.noreply.github.com>
AuthorDate: Sun May 26 08:38:20 2024 +0800

    [HUDI-7799] Optimize the access modifier of 
AbstractHoodieLogRecordReader#processNextRecord (#11308)
---
 .../org/apache/hudi/common/table/log/AbstractHoodieLogRecordReader.java | 2 +-
 .../org/apache/hudi/common/table/log/HoodieMergedLogRecordScanner.java  | 2 +-
 .../apache/hudi/common/table/log/HoodieUnMergedLogRecordScanner.java    | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/hudi-common/src/main/java/org/apache/hudi/common/table/log/AbstractHoodieLogRecordReader.java
 
b/hudi-common/src/main/java/org/apache/hudi/common/table/log/AbstractHoodieLogRecordReader.java
index 77002f2de6a..ef91c23a8b7 100644
--- 
a/hudi-common/src/main/java/org/apache/hudi/common/table/log/AbstractHoodieLogRecordReader.java
+++ 
b/hudi-common/src/main/java/org/apache/hudi/common/table/log/AbstractHoodieLogRecordReader.java
@@ -620,7 +620,7 @@ public abstract class AbstractHoodieLogRecordReader {
    *
    * @param hoodieRecord Hoodie Record to process
    */
-  public abstract <T> void processNextRecord(HoodieRecord<T> hoodieRecord) 
throws Exception;
+  protected abstract <T> void processNextRecord(HoodieRecord<T> hoodieRecord) 
throws Exception;
 
   /**
    * Process next deleted record.
diff --git 
a/hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieMergedLogRecordScanner.java
 
b/hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieMergedLogRecordScanner.java
index 8679e2455ef..f648ce42c94 100644
--- 
a/hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieMergedLogRecordScanner.java
+++ 
b/hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieMergedLogRecordScanner.java
@@ -85,7 +85,7 @@ public class HoodieMergedLogRecordScanner extends 
BaseHoodieMergedLogRecordScann
   }
 
   @Override
-  public <T> void processNextRecord(HoodieRecord<T> newRecord) throws 
IOException {
+  protected <T> void processNextRecord(HoodieRecord<T> newRecord) throws 
IOException {
     String key = newRecord.getRecordKey();
     HoodieRecord<T> prevRecord = records.get(key);
     if (prevRecord != null) {
diff --git 
a/hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieUnMergedLogRecordScanner.java
 
b/hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieUnMergedLogRecordScanner.java
index 076875677cd..de722e772b1 100644
--- 
a/hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieUnMergedLogRecordScanner.java
+++ 
b/hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieUnMergedLogRecordScanner.java
@@ -72,7 +72,7 @@ public class HoodieUnMergedLogRecordScanner extends 
AbstractHoodieLogRecordReade
   }
 
   @Override
-  public <T> void processNextRecord(HoodieRecord<T> hoodieRecord) throws 
Exception {
+  protected <T> void processNextRecord(HoodieRecord<T> hoodieRecord) throws 
Exception {
     // NOTE: Record have to be cloned here to make sure if it holds low-level 
engine-specific
     //       payload pointing into a shared, mutable (underlying) buffer we 
get a clean copy of
     //       it since these records will be put into queue of 
BoundedInMemoryExecutor.