diff --git a/hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/AzureBlobFileSystem.java b/hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/AzureBlobFileSystem.java index a041f3a618f1a..256fcc70819c3 100644 --- a/hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/AzureBlobFileSystem.java +++ b/hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/AzureBlobFileSystem.java @@ -668,6 +668,24 @@ public FileStatus[] listStatus(final Path f) throws IOException { } } + public FileStatus[] listStatus(final Path f, final String startFrom) throws IOException { + LOG.debug( + "AzureBlobFileSystem.listStatus path: {}, startFrom: {}", f.toString(), startFrom); + statIncrement(CALL_LIST_STATUS); + Path qualifiedPath = makeQualified(f); + + try { + TracingContext tracingContext = new TracingContext(clientCorrelationId, + fileSystemId, FSOperationType.LISTSTATUS, true, tracingHeaderFormat, + listener); + FileStatus[] result = abfsStore.listStatus(qualifiedPath, startFrom, tracingContext); + return result; + } catch (AzureBlobFileSystemException ex) { + checkException(f, ex); + return null; + } + } + /** * Increment of an Abfs statistic. *