address review comments

Author: shnapz

sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileSystems.java

@@ -408,7 +408,10 @@ public ResourceId apply(@Nonnull Metadata input) {
    * <p>- Number of directory<=100, report directory names (one level up);
    *
    * <p>- Otherwise, report top level only.
+   *
+   * <p>For internal use only by Beam-provided file-based connectors; not a stable public API.
    */
+  @Internal
   public static void reportSourceLineage(List<ResourceId> resourceIds) {
     final int maxLineageTargets = 100;
     if (resourceIds.size() <= maxLineageTargets) {

sdks/java/io/hadoop-file-system/src/main/java/org/apache/beam/sdk/io/hdfs/HadoopFileSystem.java

@@ -337,11 +337,6 @@ protected String getScheme() {
     return scheme;
   }
 
-  @Override
-  protected void reportLineage(HadoopResourceId resourceId, Lineage lineage) {
-    reportLineage(resourceId, lineage, LineageLevel.FILE);
-  }
-
   @Override
   protected void reportLineage(HadoopResourceId resourceId, Lineage lineage, LineageLevel level) {
     URI uri = resourceId.toPath().toUri();

sdks/java/io/hadoop-file-system/src/test/java/org/apache/beam/sdk/io/hdfs/HadoopFileSystemTest.java

@@ -40,6 +40,7 @@
 import java.util.Collections;
 import java.util.List;
 import java.util.Objects;
+import org.apache.beam.sdk.io.FileSystem;
 import org.apache.beam.sdk.io.FileSystems;
 import org.apache.beam.sdk.io.TextIO;
 import org.apache.beam.sdk.io.fs.CreateOptions.StandardCreateOptions;
@@ -496,7 +497,7 @@ public void testReportLineage() {
   private void verifyLineage(String uri, List<String> expected) {
     HadoopResourceId resourceId = new HadoopResourceId(URI.create(uri));
     Lineage mockLineage = mock(Lineage.class);
-    fileSystem.reportLineage(resourceId, mockLineage);
+    fileSystem.reportLineage(resourceId, mockLineage, FileSystem.LineageLevel.FILE);
     verify(mockLineage, times(1)).add("hdfs", expected, "/");
   }