Add @nullable for commonPrefixVisitor

apache · Sep 25, 2024 · 1eb294f · 1eb294f
1 parent 9682eef
commit 1eb294f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...inot-file-system/pinot-s3/src/main/java/org/apache/pinot/plugin/filesystem/S3PinotFS.java b/...inot-file-system/pinot-s3/src/main/java/org/apache/pinot/plugin/filesystem/S3PinotFS.java
@@ -545,7 +545,7 @@ private static String getNormalizedFileKey(CommonPrefix commonPrefix) {
   }
 
   private void visitFiles(URI fileUri, boolean recursive, Consumer<S3Object> objectVisitor,
-      Consumer<CommonPrefix> commonPrefixVisitor) throws IOException {
+      @Nullable Consumer<CommonPrefix> commonPrefixVisitor) throws IOException {
     try {
       String continuationToken = null;
       boolean isDone = false;