AzureSDKAutomation · openapi-sdkautomation · Jan 21, 2022
diff --git a/sdk/videoanalyzer/azure-resourcemanager-videoanalyzer/CHANGELOG.md b/sdk/videoanalyzer/azure-resourcemanager-videoanalyzer/CHANGELOG.md
@@ -1,6 +1,8 @@
 # Release History
 
-## 1.0.0-beta.5 (Unreleased)
+## 1.0.0-beta.1 (2022-01-21)
+
+- Azure Resource Manager Video Analyzer client library for Java. This package contains Microsoft Azure SDK for Video Analyzer Management SDK. Azure Video Analyzer provides a platform for you to build intelligent video applications that span the edge and the cloud. Package tag package-preview-2021-11. For documentation on how to use this package, please see [Azure Management Libraries for Java](https://aka.ms/azsdk/java/mgmt).
 
 ### Features Added
 

diff --git a/sdk/videoanalyzer/azure-resourcemanager-videoanalyzer/README.md b/sdk/videoanalyzer/azure-resourcemanager-videoanalyzer/README.md
@@ -32,7 +32,7 @@ Various documentation is available to help you get started
 <dependency>
     <groupId>com.azure.resourcemanager</groupId>
     <artifactId>azure-resourcemanager-videoanalyzer</artifactId>
-    <version>1.0.0-beta.4</version>
+    <version>1.0.0-beta.5</version>
 </dependency>
 ```
 [//]: # ({x-version-update-end})

diff --git a/...oanalyzer/src/main/java/com/azure/resourcemanager/videoanalyzer/VideoAnalyzerManager.java b/...oanalyzer/src/main/java/com/azure/resourcemanager/videoanalyzer/VideoAnalyzerManager.java
@@ -8,6 +8,7 @@
 import com.azure.core.http.HttpClient;
 import com.azure.core.http.HttpPipeline;
 import com.azure.core.http.HttpPipelineBuilder;
+import com.azure.core.http.HttpPipelinePosition;
 import com.azure.core.http.policy.AddDatePolicy;
 import com.azure.core.http.policy.HttpLogOptions;
 import com.azure.core.http.policy.HttpLoggingPolicy;
@@ -61,6 +62,7 @@
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Objects;
+import java.util.stream.Collectors;
 
 /**
  * Entry point to VideoAnalyzerManager. Azure Video Analyzer provides a platform for you to build intelligent video
@@ -237,7 +239,7 @@ public VideoAnalyzerManager authenticate(TokenCredential credential, AzureProfil
                 .append("-")
                 .append("com.azure.resourcemanager.videoanalyzer")
                 .append("/")
-                .append("1.0.0-beta.4");
+                .append("1.0.0-beta.1");
             if (!Configuration.getGlobalConfiguration().get("AZURE_TELEMETRY_DISABLED", false)) {
                 userAgentBuilder
                     .append(" (")
@@ -260,11 +262,24 @@ public VideoAnalyzerManager authenticate(TokenCredential credential, AzureProfil
             List<HttpPipelinePolicy> policies = new ArrayList<>();
             policies.add(new UserAgentPolicy(userAgentBuilder.toString()));
             policies.add(new RequestIdPolicy());
+            policies
+                .addAll(
+                    this
+                        .policies
+                        .stream()
+                        .filter(p -> p.getPipelinePosition() == HttpPipelinePosition.PER_CALL)
+                        .collect(Collectors.toList()));
             HttpPolicyProviders.addBeforeRetryPolicies(policies);
             policies.add(retryPolicy);
             policies.add(new AddDatePolicy());
             policies.add(new ArmChallengeAuthenticationPolicy(credential, scopes.toArray(new String[0])));
-            policies.addAll(this.policies);
+            policies
+                .addAll(
+                    this
+                        .policies
+                        .stream()
+                        .filter(p -> p.getPipelinePosition() == HttpPipelinePosition.PER_RETRY)
+                        .collect(Collectors.toList()));
             HttpPolicyProviders.addAfterRetryPolicies(policies);
             policies.add(new HttpLoggingPolicy(httpLogOptions));
             HttpPipeline httpPipeline =

diff --git a/...er/src/main/java/com/azure/resourcemanager/videoanalyzer/fluent/AccessPoliciesClient.java b/...er/src/main/java/com/azure/resourcemanager/videoanalyzer/fluent/AccessPoliciesClient.java
@@ -67,7 +67,8 @@ PagedIterable<AccessPolicyEntityInner> list(
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return access policies help define the authentication rules, and control access to specific video resources.
+     * @return access policies help define the authentication rules, and control access to specific video resources
+     *     along with {@link Response}.
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     Response<AccessPolicyEntityInner> getWithResponse(
@@ -100,7 +101,8 @@ AccessPolicyEntityInner createOrUpdate(
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return access policies help define the authentication rules, and control access to specific video resources.
+     * @return access policies help define the authentication rules, and control access to specific video resources
+     *     along with {@link Response}.
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     Response<AccessPolicyEntityInner> createOrUpdateWithResponse(
@@ -133,7 +135,7 @@ Response<AccessPolicyEntityInner> createOrUpdateWithResponse(
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return the response.
+     * @return the {@link Response}.
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     Response<Void> deleteWithResponse(
@@ -166,7 +168,8 @@ AccessPolicyEntityInner update(
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return access policies help define the authentication rules, and control access to specific video resources.
+     * @return access policies help define the authentication rules, and control access to specific video resources
+     *     along with {@link Response}.
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     Response<AccessPolicyEntityInner> updateWithResponse(

diff --git a/...lyzer/src/main/java/com/azure/resourcemanager/videoanalyzer/fluent/EdgeModulesClient.java b/...lyzer/src/main/java/com/azure/resourcemanager/videoanalyzer/fluent/EdgeModulesClient.java
@@ -69,7 +69,7 @@ PagedIterable<EdgeModuleEntityInner> list(
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return the representation of an edge module.
+     * @return the representation of an edge module along with {@link Response}.
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     Response<EdgeModuleEntityInner> getWithResponse(
@@ -112,7 +112,7 @@ EdgeModuleEntityInner createOrUpdate(
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return the representation of an edge module.
+     * @return the representation of an edge module along with {@link Response}.
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     Response<EdgeModuleEntityInner> createOrUpdateWithResponse(
@@ -149,7 +149,7 @@ Response<EdgeModuleEntityInner> createOrUpdateWithResponse(
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return the response.
+     * @return the {@link Response}.
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     Response<Void> deleteWithResponse(
@@ -192,7 +192,7 @@ EdgeModuleProvisioningTokenInner listProvisioningToken(
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return provisioning token properties.
+     * @return provisioning token properties along with {@link Response}.
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     Response<EdgeModuleProvisioningTokenInner> listProvisioningTokenWithResponse(

diff --git a/...a/com/azure/resourcemanager/videoanalyzer/fluent/LivePipelineOperationStatusesClient.java b/...a/com/azure/resourcemanager/videoanalyzer/fluent/LivePipelineOperationStatusesClient.java
@@ -39,7 +39,7 @@ LivePipelineOperationStatusInner get(
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return the operation status of a live pipeline.
+     * @return the operation status of a live pipeline along with {@link Response}.
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     Response<LivePipelineOperationStatusInner> getWithResponse(

diff --git a/...zer/src/main/java/com/azure/resourcemanager/videoanalyzer/fluent/LivePipelinesClient.java b/...zer/src/main/java/com/azure/resourcemanager/videoanalyzer/fluent/LivePipelinesClient.java
@@ -13,6 +13,7 @@
 import com.azure.core.util.polling.SyncPoller;
 import com.azure.resourcemanager.videoanalyzer.fluent.models.LivePipelineInner;
 import com.azure.resourcemanager.videoanalyzer.models.LivePipelineUpdate;
+import reactor.core.publisher.Mono;
 
 /** An instance of this class provides access to all the operations defined in LivePipelinesClient. */
 public interface LivePipelinesClient {
@@ -75,7 +76,7 @@ PagedIterable<LivePipelineInner> list(
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
      * @return live pipeline represents a unique instance of a live topology, used for real-time ingestion, archiving
-     *     and publishing of content for a unique RTSP camera.
+     *     and publishing of content for a unique RTSP camera along with {@link Response}.
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     Response<LivePipelineInner> getWithResponse(
@@ -110,7 +111,7 @@ LivePipelineInner createOrUpdate(
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
      * @return live pipeline represents a unique instance of a live topology, used for real-time ingestion, archiving
-     *     and publishing of content for a unique RTSP camera.
+     *     and publishing of content for a unique RTSP camera along with {@link Response}.
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     Response<LivePipelineInner> createOrUpdateWithResponse(
@@ -143,7 +144,7 @@ Response<LivePipelineInner> createOrUpdateWithResponse(
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return the response.
+     * @return the {@link Response}.
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     Response<Void> deleteWithResponse(
@@ -180,7 +181,7 @@ LivePipelineInner update(
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
      * @return live pipeline represents a unique instance of a live topology, used for real-time ingestion, archiving
-     *     and publishing of content for a unique RTSP camera.
+     *     and publishing of content for a unique RTSP camera along with {@link Response}.
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     Response<LivePipelineInner> updateWithResponse(
@@ -199,7 +200,7 @@ Response<LivePipelineInner> updateWithResponse(
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return the completion.
+     * @return the {@link Response} on successful completion of {@link Mono}.
      */
     @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
     SyncPoller<PollResult<Void>, Void> beginActivate(
@@ -215,7 +216,7 @@ SyncPoller<PollResult<Void>, Void> beginActivate(
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return the completion.
+     * @return the {@link Response} on successful completion of {@link Mono}.
      */
     @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
     SyncPoller<PollResult<Void>, Void> beginActivate(
@@ -257,7 +258,7 @@ SyncPoller<PollResult<Void>, Void> beginActivate(
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return the completion.
+     * @return the {@link Response} on successful completion of {@link Mono}.
      */
     @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
     SyncPoller<PollResult<Void>, Void> beginDeactivate(
@@ -273,7 +274,7 @@ SyncPoller<PollResult<Void>, Void> beginDeactivate(
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return the completion.
+     * @return the {@link Response} on successful completion of {@link Mono}.
      */
     @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
     SyncPoller<PollResult<Void>, Void> beginDeactivate(

diff --git a/...nalyzer/src/main/java/com/azure/resourcemanager/videoanalyzer/fluent/LocationsClient.java b/...nalyzer/src/main/java/com/azure/resourcemanager/videoanalyzer/fluent/LocationsClient.java
@@ -36,7 +36,7 @@ CheckNameAvailabilityResponseInner checkNameAvailability(
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return the check availability result.
+     * @return the check availability result along with {@link Response}.
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     Response<CheckNameAvailabilityResponseInner> checkNameAvailabilityWithResponse(

diff --git a/.../src/main/java/com/azure/resourcemanager/videoanalyzer/fluent/OperationResultsClient.java b/.../src/main/java/com/azure/resourcemanager/videoanalyzer/fluent/OperationResultsClient.java
@@ -38,7 +38,7 @@ public interface OperationResultsClient {
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return private endpoint connection operation result.
+     * @return private endpoint connection operation result along with {@link Response}.
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     Response<PrivateEndpointConnectionInner> getWithResponse(

diff --git a/...src/main/java/com/azure/resourcemanager/videoanalyzer/fluent/OperationStatusesClient.java b/...src/main/java/com/azure/resourcemanager/videoanalyzer/fluent/OperationStatusesClient.java
@@ -39,7 +39,7 @@ VideoAnalyzerPrivateEndpointConnectionOperationStatusInner get(
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return private endpoint connection operation status.
+     * @return private endpoint connection operation status along with {@link Response}.
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     Response<VideoAnalyzerPrivateEndpointConnectionOperationStatusInner> getWithResponse(

diff --git a/...alyzer/src/main/java/com/azure/resourcemanager/videoanalyzer/fluent/OperationsClient.java b/...alyzer/src/main/java/com/azure/resourcemanager/videoanalyzer/fluent/OperationsClient.java
@@ -29,7 +29,7 @@ public interface OperationsClient {
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return a collection of Operation items.
+     * @return a collection of Operation items along with {@link Response}.
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     Response<OperationCollectionInner> listWithResponse(Context context);

diff --git a/...va/com/azure/resourcemanager/videoanalyzer/fluent/PipelineJobOperationStatusesClient.java b/...va/com/azure/resourcemanager/videoanalyzer/fluent/PipelineJobOperationStatusesClient.java
@@ -39,7 +39,7 @@ PipelineJobOperationStatusInner get(
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return the operation status of a pipeline job with the given operationId.
+     * @return the operation status of a pipeline job with the given operationId along with {@link Response}.
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     Response<PipelineJobOperationStatusInner> getWithResponse(