diff --git a/java/azure-perfstress/pom.xml b/java/azure-perfstress/pom.xml index d2517e4372a4b..49ee8fa9d5746 100644 --- a/java/azure-perfstress/pom.xml +++ b/java/azure-perfstress/pom.xml @@ -39,7 +39,7 @@ com.azure azure-core-http-netty - 1.0.0-preview.6 + 1.0.0 diff --git a/java/azure-storage-blob-perfstress/pom.xml b/java/azure-storage-blob-perfstress/pom.xml index 424f1a9b32338..b29befa96eba6 100644 --- a/java/azure-storage-blob-perfstress/pom.xml +++ b/java/azure-storage-blob-perfstress/pom.xml @@ -18,7 +18,7 @@ com.azure azure-storage-blob - 12.0.0-preview.4 + 12.0.0-preview.5 com.azure diff --git a/java/azure-storage-blob-perfstress/src/main/java/com/azure/storage/blob/perfstress/DownloadTest.java b/java/azure-storage-blob-perfstress/src/main/java/com/azure/storage/blob/perfstress/DownloadTest.java index 40059b0cfa160..66d553e87ec17 100644 --- a/java/azure-storage-blob-perfstress/src/main/java/com/azure/storage/blob/perfstress/DownloadTest.java +++ b/java/azure-storage-blob-perfstress/src/main/java/com/azure/storage/blob/perfstress/DownloadTest.java @@ -25,7 +25,7 @@ public DownloadTest(SizeOptions options) { public Mono GlobalSetupAsync() { return super.GlobalSetupAsync() - .then(_blobAsyncClient.upload(RandomFlux.create(Options.Size), new ParallelTransferOptions())) + .then(_blobAsyncClient.upload(RandomFlux.create(Options.Size), null)) .then(); } diff --git a/java/azure-storage-blob-perfstress/src/main/java/com/azure/storage/blob/perfstress/GetBlobsTest.java b/java/azure-storage-blob-perfstress/src/main/java/com/azure/storage/blob/perfstress/GetBlobsTest.java index 4d1aa8ae7931f..34ab04109ca37 100644 --- a/java/azure-storage-blob-perfstress/src/main/java/com/azure/storage/blob/perfstress/GetBlobsTest.java +++ b/java/azure-storage-blob-perfstress/src/main/java/com/azure/storage/blob/perfstress/GetBlobsTest.java @@ -18,17 +18,17 @@ public Mono GlobalSetupAsync() { return super.GlobalSetupAsync().then( Flux.range(0, Options.Count) .map(i -> "getblobstest-" + UUID.randomUUID()) - .flatMap(b -> BlobContainerAsyncClient.getBlobAsyncClient(b).upload(Flux.empty(), new ParallelTransferOptions())) + .flatMap(b -> BlobContainerAsyncClient.getBlobAsyncClient(b).upload(Flux.empty(), null)) .then()); } @Override public void Run() { - BlobContainerClient.listBlobsFlat().forEach(b -> {}); + BlobContainerClient.listBlobs().forEach(b -> {}); } @Override public Mono RunAsync() { - return BlobContainerAsyncClient.listBlobsFlat().then(); + return BlobContainerAsyncClient.listBlobs().then(); } } \ No newline at end of file diff --git a/java/azure-storage-blob-perfstress/src/main/java/com/azure/storage/blob/perfstress/UploadBlockBlobTest.java b/java/azure-storage-blob-perfstress/src/main/java/com/azure/storage/blob/perfstress/UploadBlockBlobTest.java index f126428ac66e7..ed9da58695a78 100644 --- a/java/azure-storage-blob-perfstress/src/main/java/com/azure/storage/blob/perfstress/UploadBlockBlobTest.java +++ b/java/azure-storage-blob-perfstress/src/main/java/com/azure/storage/blob/perfstress/UploadBlockBlobTest.java @@ -16,15 +16,11 @@ public UploadBlockBlobTest(SizeOptions options) { @Override public void Run() { - try { - _blockBlobClient.upload(RandomStream.create(Options.Size), Options.Size); - } catch (IOException e) { - throw new RuntimeException(e); - } + _blockBlobClient.upload(RandomStream.create(Options.Size), Options.Size, true); } @Override public Mono RunAsync() { - return _blockBlobAsyncClient.upload(RandomFlux.create(Options.Size), Options.Size).then(); + return _blockBlobAsyncClient.upload(RandomFlux.create(Options.Size), Options.Size, true).then(); } } \ No newline at end of file diff --git a/java/azure-storage-blob-perfstress/src/main/java/com/azure/storage/blob/perfstress/UploadFromFileTest.java b/java/azure-storage-blob-perfstress/src/main/java/com/azure/storage/blob/perfstress/UploadFromFileTest.java index ded65ed93e92e..93e6a882ef04e 100644 --- a/java/azure-storage-blob-perfstress/src/main/java/com/azure/storage/blob/perfstress/UploadFromFileTest.java +++ b/java/azure-storage-blob-perfstress/src/main/java/com/azure/storage/blob/perfstress/UploadFromFileTest.java @@ -57,15 +57,11 @@ private Mono DeleteTempFile() { @Override public void Run() { - try { - _blobClient.uploadFromFile(tempFile.toString()); - } catch (IOException e) { - throw new RuntimeException(e); - } + _blobClient.uploadFromFile(tempFile.toString(), true); } @Override public Mono RunAsync() { - return _blobAsyncClient.uploadFromFile(tempFile.toString()); + return _blobAsyncClient.uploadFromFile(tempFile.toString(), true); } } \ No newline at end of file diff --git a/java/azure-storage-blob-perfstress/src/main/java/com/azure/storage/blob/perfstress/UploadTest.java b/java/azure-storage-blob-perfstress/src/main/java/com/azure/storage/blob/perfstress/UploadTest.java index ec6ef0d3d29bc..37ab78f9280bd 100644 --- a/java/azure-storage-blob-perfstress/src/main/java/com/azure/storage/blob/perfstress/UploadTest.java +++ b/java/azure-storage-blob-perfstress/src/main/java/com/azure/storage/blob/perfstress/UploadTest.java @@ -19,6 +19,6 @@ public void Run() { @Override public Mono RunAsync() { - return _blobAsyncClient.upload(RandomFlux.create(Options.Size), null).then(); + return _blobAsyncClient.upload(RandomFlux.create(Options.Size), null, true).then(); } } \ No newline at end of file