listblob startsFrom changes (#46220)

* listblob startsFrom changes

* adding recordings

* fixing review comments

* adding listblobsbyhierachy tests

Author: gunjansingh-msft

sdk/storage/azure-storage-blob/assets.json

@@ -2,5 +2,5 @@
   "AssetsRepo": "Azure/azure-sdk-assets",
   "AssetsRepoPrefixPath": "java",
   "TagPrefix": "java/storage/azure-storage-blob",
-  "Tag": "java/storage/azure-storage-blob_80c07fe827"
+  "Tag": "java/storage/azure-storage-blob_098e26235c"
 }

sdk/storage/azure-storage-blob/src/main/java/com/azure/storage/blob/BlobContainerAsyncClient.java

@@ -1172,9 +1172,10 @@ PagedFlux<BlobItem> listBlobsFlatWithOptionalTimeout(ListBlobsOptions options, S
         ArrayList<ListBlobsIncludeItem> include
             = options.getDetails().toList().isEmpty() ? null : options.getDetails().toList();
 
-        return StorageImplUtils.applyOptionalTimeout(this.azureBlobStorage.getContainers()
-            .listBlobFlatSegmentWithResponseAsync(containerName, options.getPrefix(), marker,
-                options.getMaxResultsPerPage(), include, null, null, Context.NONE),
+        return StorageImplUtils.applyOptionalTimeout(
+            this.azureBlobStorage.getContainers()
+                .listBlobFlatSegmentWithResponseAsync(containerName, options.getPrefix(), marker,
+                    options.getMaxResultsPerPage(), include, options.getStartFrom(), null, null, Context.NONE),
             timeout);
     }
 
@@ -1301,7 +1302,8 @@ PagedFlux<BlobItem> listBlobsHierarchyWithOptionalTimeout(String delimiter, List
                     // Note that this prefers the value passed to .byPage(int) over the value on the options
                     finalOptions = new ListBlobsOptions().setMaxResultsPerPage(pageSize)
                         .setPrefix(options.getPrefix())
-                        .setDetails(options.getDetails());
+                        .setDetails(options.getDetails())
+                        .setStartFrom(options.getStartFrom());
                 }
             } else {
                 finalOptions = options;
@@ -1337,9 +1339,10 @@ PagedFlux<BlobItem> listBlobsHierarchyWithOptionalTimeout(String delimiter, List
         ArrayList<ListBlobsIncludeItem> include
             = options.getDetails().toList().isEmpty() ? null : options.getDetails().toList();
 
-        return StorageImplUtils.applyOptionalTimeout(this.azureBlobStorage.getContainers()
-            .listBlobHierarchySegmentWithResponseAsync(containerName, delimiter, options.getPrefix(), marker,
-                options.getMaxResultsPerPage(), include, null, null, Context.NONE),
+        return StorageImplUtils.applyOptionalTimeout(
+            this.azureBlobStorage.getContainers()
+                .listBlobHierarchySegmentWithResponseAsync(containerName, delimiter, options.getPrefix(), marker,
+                    options.getMaxResultsPerPage(), include, options.getStartFrom(), null, null, Context.NONE),
             timeout);
     }
 

sdk/storage/azure-storage-blob/src/main/java/com/azure/storage/blob/BlobContainerClient.java

@@ -1029,7 +1029,9 @@ public PagedIterable<BlobItem> listBlobs(ListBlobsOptions options, String contin
             if (options != null) {
                 finalOptions.setMaxResultsPerPage(options.getMaxResultsPerPage())
                     .setPrefix(options.getPrefix())
+                    .setStartFrom(options.getStartFrom())
                     .setDetails(options.getDetails());
+
             }
             /*
             If pageSize was not set in a .byPage(int) method, the page size from options will be preserved.
@@ -1044,7 +1046,8 @@ public PagedIterable<BlobItem> listBlobs(ListBlobsOptions options, String contin
             Callable<ResponseBase<ContainersListBlobFlatSegmentHeaders, ListBlobsFlatSegmentResponse>> operation
                 = () -> this.azureBlobStorage.getContainers()
                     .listBlobFlatSegmentWithResponse(containerName, finalOptions.getPrefix(), nextMarker,
-                        finalOptions.getMaxResultsPerPage(), include, null, null, Context.NONE);
+                        finalOptions.getMaxResultsPerPage(), include, finalOptions.getStartFrom(), null, null,
+                        Context.NONE);
 
             ResponseBase<ContainersListBlobFlatSegmentHeaders, ListBlobsFlatSegmentResponse> response
                 = StorageImplUtils.sendRequest(operation, timeout, BlobStorageException.class);
@@ -1162,7 +1165,8 @@ public PagedIterable<BlobItem> listBlobsByHierarchy(String delimiter, ListBlobsO
             if (options != null) {
                 finalOptions.setMaxResultsPerPage(options.getMaxResultsPerPage())
                     .setPrefix(options.getPrefix())
-                    .setDetails(options.getDetails());
+                    .setDetails(options.getDetails())
+                    .setStartFrom(options.getStartFrom());
             }
             /*
             If pageSize was not set in a .byPage(int) method, the page size from options will be preserved.
@@ -1188,7 +1192,7 @@ private PagedResponse<BlobItem> listBlobsHierarchySegment(String marker, String
         Callable<ResponseBase<ContainersListBlobHierarchySegmentHeaders, ListBlobsHierarchySegmentResponse>> operation
             = () -> azureBlobStorage.getContainers()
                 .listBlobHierarchySegmentWithResponse(containerName, delimiter, options.getPrefix(), marker,
-                    options.getMaxResultsPerPage(), include, null, null, Context.NONE);
+                    options.getMaxResultsPerPage(), include, options.getStartFrom(), null, null, Context.NONE);
 
         ResponseBase<ContainersListBlobHierarchySegmentHeaders, ListBlobsHierarchySegmentResponse> response
             = StorageImplUtils.sendRequest(operation, timeout, BlobStorageException.class);