@Override
  public FindResult findEntriesSince(String partitionPath, FindToken findToken, long maxTotalSizeOfEntries)
      throws CloudStorageException {
    try {
      return azureReplicationFeed.getNextEntriesAndUpdatedToken(findToken, maxTotalSizeOfEntries, partitionPath);
    } catch (CosmosException cex) {
      throw toCloudStorageException("Failed to query blobs for partition " + partitionPath, cex);
    }
  }
Get metadata for specified list of blobs asynchronously.
@param blobIds {@link List} of {@link BlobId}s to get metadata of.
@return a {@link CompletableFuture} that will eventually contain either the {@link List} of
        {@link CloudBlobMetadata} for the blobs list or an exception if an error occurred.
ambry-cloud/src/main/java/com/github/ambry/cloud/azure/AzureCloudDestination.java