rename scanner (#39304)

ahmedabu98 · web-flow · commit 5a3bbbaba0f5 · 2026-07-13T12:18:11.000-04:00
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
@@ -51,7 +51,7 @@
 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 @@ public void process(@Element Long snapshotId, MultiOutputReceiver out) throws IO
     // 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/BeamBaseIncrementalChangelogScan.java b/sdks/java/io/iceberg/src/main/java/org/apache/iceberg/BeamBaseIncrementalChangelogScan.java
@@ -58,7 +58,7 @@
  * 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 @@ private static DeleteFileIndex createEmptyInstance() {
     }
   }
 
-  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

Original file line number	Diff line number	Diff line change
`@@ -58,7 +58,7 @@`
`58`	`58`	`* Copied over from <a href="https://github.com/apache/iceberg/pull/14264/">Iceberg PR #14264</a>.`
`59`	`59`	`*/`
`60`	`60`	`@SuppressWarnings("nullness")`
`61`		`-public class BaseIncrementalChangelogScan`
	`61`	`+public class BeamBaseIncrementalChangelogScan`
`62`	`62`	`extends BaseIncrementalScan<`
`63`	`63`	`IncrementalChangelogScan, ChangelogScanTask, ScanTaskGroup<ChangelogScanTask>>`
`64`	`64`	`implements IncrementalChangelogScan {`
`@@ -80,20 +80,20 @@ private static DeleteFileIndex createEmptyInstance() {`
`80`	`80`	`}`
`81`	`81`	`}`
`82`	`82`
`83`		`- private static final Logger LOG = LoggerFactory.getLogger(BaseIncrementalChangelogScan.class);`
	`83`	`+ private static final Logger LOG = LoggerFactory.getLogger(BeamBaseIncrementalChangelogScan.class);`
`84`	`84`
`85`		`- public BaseIncrementalChangelogScan(Table table) {`
	`85`	`+ public BeamBaseIncrementalChangelogScan(Table table) {`
`86`	`86`	`this(table, table.schema(), TableScanContext.empty());`
`87`	`87`	`}`
`88`	`88`
`89`		`- private BaseIncrementalChangelogScan(Table table, Schema schema, TableScanContext context) {`
	`89`	`+ private BeamBaseIncrementalChangelogScan(Table table, Schema schema, TableScanContext context) {`
`90`	`90`	`super(table, schema, context);`
`91`	`91`	`}`
`92`	`92`
`93`	`93`	`@Override`
`94`	`94`	`protected IncrementalChangelogScan newRefinedScan(`
`95`	`95`	`Table newTable, Schema newSchema, TableScanContext newContext) {`
`96`		`- return new BaseIncrementalChangelogScan(newTable, newSchema, newContext);`
	`96`	`+ return new BeamBaseIncrementalChangelogScan(newTable, newSchema, newContext);`
`97`	`97`	`}`
`98`	`98`
`99`	`99`	`// Private fields to track build call count and cache (accessed via package-private methods for`