(beam) branch master updated: rename scanner (#39304)

[derrick]

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

derrickaw pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 5a3bbbaba0f rename scanner (#39304)
5a3bbbaba0f is described below

commit 5a3bbbaba0f570cca884b103a73561c93919bd09
Author: Ahmed Abualsaud <65791736+ahmedab...@users.noreply.github.com>
AuthorDate: Mon Jul 13 11:18:11 2026 -0500

    rename scanner (#39304)
---
 .../org/apache/beam/sdk/io/iceberg/cdc/ChangelogScanner.java   |  4 ++--
 ...hangelogScan.java => BeamBaseIncrementalChangelogScan.java} | 10 +++++-----
 2 files changed, 7 insertions(+), 7 deletions(-)

diff --git 
a/sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/cdc/ChangelogScanner.java
 
b/sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/cdc/ChangelogScanner.java
index 0000884c90a..17ab4c5d30c 100644
--- 
a/sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/cdc/ChangelogScanner.java
+++ 
b/sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/cdc/ChangelogScanner.java
@@ -51,7 +51,7 @@ import org.apache.beam.sdk.values.Row;
 import org.apache.beam.sdk.values.TupleTag;
 import 
org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Iterables;
 import org.apache.iceberg.AddedRowsScanTask;
-import org.apache.iceberg.BaseIncrementalChangelogScan;
+import org.apache.iceberg.BeamBaseIncrementalChangelogScan;
 import org.apache.iceberg.ChangelogScanTask;
 import org.apache.iceberg.DataFile;
 import org.apache.iceberg.DataOperations;
@@ -230,7 +230,7 @@ class ChangelogScanner
     // TODO(ahmedabu98): replace this with table.newIncrementalChangelogScan() 
when
     //  https://github.com/apache/iceberg/pull/14264/ gets merged and released.
     IncrementalChangelogScan scan =
-        new BaseIncrementalChangelogScan(table)
+        new BeamBaseIncrementalChangelogScan(table)
             .toSnapshot(snapshotId)
             .project(scanConfig.getProjectedSchema());
     if (fromSnapshotId != null) {
diff --git 
a/sdks/java/io/iceberg/src/main/java/org/apache/iceberg/BaseIncrementalChangelogScan.java
 
b/sdks/java/io/iceberg/src/main/java/org/apache/iceberg/BeamBaseIncrementalChangelogScan.java
similarity index 99%
rename from 
sdks/java/io/iceberg/src/main/java/org/apache/iceberg/BaseIncrementalChangelogScan.java
rename to 
sdks/java/io/iceberg/src/main/java/org/apache/iceberg/BeamBaseIncrementalChangelogScan.java
index 6b12e16690b..a7fe19218c1 100644
--- 
a/sdks/java/io/iceberg/src/main/java/org/apache/iceberg/BaseIncrementalChangelogScan.java
+++ 
b/sdks/java/io/iceberg/src/main/java/org/apache/iceberg/BeamBaseIncrementalChangelogScan.java
@@ -58,7 +58,7 @@ import org.slf4j.LoggerFactory;
  * Copied over from <a 
href="https://github.com/apache/iceberg/pull/14264/";>Iceberg PR #14264</a>.
  */
 @SuppressWarnings("nullness")
-public class BaseIncrementalChangelogScan
+public class BeamBaseIncrementalChangelogScan
     extends BaseIncrementalScan<
         IncrementalChangelogScan, ChangelogScanTask, 
ScanTaskGroup<ChangelogScanTask>>
     implements IncrementalChangelogScan {
@@ -80,20 +80,20 @@ public class BaseIncrementalChangelogScan
     }
   }
 
-  private static final Logger LOG = 
LoggerFactory.getLogger(BaseIncrementalChangelogScan.class);
+  private static final Logger LOG = 
LoggerFactory.getLogger(BeamBaseIncrementalChangelogScan.class);
 
-  public BaseIncrementalChangelogScan(Table table) {
+  public BeamBaseIncrementalChangelogScan(Table table) {
     this(table, table.schema(), TableScanContext.empty());
   }
 
-  private BaseIncrementalChangelogScan(Table table, Schema schema, 
TableScanContext context) {
+  private BeamBaseIncrementalChangelogScan(Table table, Schema schema, 
TableScanContext context) {
     super(table, schema, context);
   }
 
   @Override
   protected IncrementalChangelogScan newRefinedScan(
       Table newTable, Schema newSchema, TableScanContext newContext) {
-    return new BaseIncrementalChangelogScan(newTable, newSchema, newContext);
+    return new BeamBaseIncrementalChangelogScan(newTable, newSchema, 
newContext);
   }
 
   // Private fields to track build call count and cache (accessed via 
package-private methods for