From 949d88d8b07fc70caebf524f93a8a254e12a18fa Mon Sep 17 00:00:00 2001 From: SDKAuto Date: Wed, 5 Jan 2022 09:44:24 +0000 Subject: [PATCH] CodeGen from PR 16886 in Azure/azure-rest-api-specs Track2 modify readme.go.md 3 (#16886) * Track2 modify readme.go.md * directive modelerfour.lenient-model-deduplication=true --- .../azure-resourcemanager-kusto/CHANGELOG.md | 4 +- .../azure-resourcemanager-kusto/README.md | 2 +- .../resourcemanager/kusto/KustoManager.java | 19 +++- .../AttachedDatabaseConfigurationsClient.java | 8 +- .../ClusterPrincipalAssignmentsClient.java | 8 +- .../kusto/fluent/ClustersClient.java | 36 +++---- .../kusto/fluent/DataConnectionsClient.java | 16 ++-- .../DatabasePrincipalAssignmentsClient.java | 8 +- .../kusto/fluent/DatabasesClient.java | 12 +-- .../fluent/ManagedPrivateEndpointsClient.java | 12 +-- .../PrivateEndpointConnectionsClient.java | 8 +- .../kusto/fluent/ScriptsClient.java | 12 +-- ...achedDatabaseConfigurationsClientImpl.java | 21 ++-- ...ClusterPrincipalAssignmentsClientImpl.java | 21 ++-- .../implementation/ClustersClientImpl.java | 96 ++++++++++--------- .../DataConnectionsClientImpl.java | 41 ++++---- ...atabasePrincipalAssignmentsClientImpl.java | 21 ++-- .../implementation/DatabasesClientImpl.java | 39 +++++--- .../ManagedPrivateEndpointsClientImpl.java | 31 +++--- .../PrivateEndpointConnectionsClientImpl.java | 21 ++-- .../implementation/ScriptsClientImpl.java | 31 +++--- ...atabaseConfigurationsCheckNameRequest.java | 2 +- .../kusto/models/ClusterCheckNameRequest.java | 2 +- ...erPrincipalAssignmentCheckNameRequest.java | 2 +- .../DataConnectionCheckNameRequest.java | 2 +- ...sePrincipalAssignmentCheckNameRequest.java | 2 +- ...nagedPrivateEndpointsCheckNameRequest.java | 2 +- .../kusto/models/ScriptCheckNameRequest.java | 2 +- 28 files changed, 260 insertions(+), 221 deletions(-) diff --git a/sdk/kusto/azure-resourcemanager-kusto/CHANGELOG.md b/sdk/kusto/azure-resourcemanager-kusto/CHANGELOG.md index 0ef14a22d29a8..9153d9e99d706 100644 --- a/sdk/kusto/azure-resourcemanager-kusto/CHANGELOG.md +++ b/sdk/kusto/azure-resourcemanager-kusto/CHANGELOG.md @@ -1,6 +1,8 @@ # Release History -## 1.0.0-beta.4 (Unreleased) +## 1.0.0-beta.1 (2022-01-05) + +- Azure Resource Manager Kusto client library for Java. This package contains Microsoft Azure SDK for Kusto Management SDK. The Azure Kusto management API provides a RESTful set of web services that interact with Azure Kusto services to manage your clusters and databases. The API enables you to create, update, and delete clusters and databases. Package tag package-2021-08-27. 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/kusto/azure-resourcemanager-kusto/README.md b/sdk/kusto/azure-resourcemanager-kusto/README.md index a64bd78236290..ac19ffe65da3f 100644 --- a/sdk/kusto/azure-resourcemanager-kusto/README.md +++ b/sdk/kusto/azure-resourcemanager-kusto/README.md @@ -32,7 +32,7 @@ Various documentation is available to help you get started com.azure.resourcemanager azure-resourcemanager-kusto - 1.0.0-beta.3 + 1.0.0-beta.4 ``` [//]: # ({x-version-update-end}) diff --git a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/KustoManager.java b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/KustoManager.java index 45eff1c72dc04..47c518418805c 100644 --- a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/KustoManager.java +++ b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/KustoManager.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; @@ -51,6 +52,7 @@ import java.util.ArrayList; import java.util.List; import java.util.Objects; +import java.util.stream.Collectors; /** * Entry point to KustoManager. The Azure Kusto management API provides a RESTful set of web services that interact with @@ -218,7 +220,7 @@ public KustoManager authenticate(TokenCredential credential, AzureProfile profil .append("-") .append("com.azure.resourcemanager.kusto") .append("/") - .append("1.0.0-beta.3"); + .append("1.0.0-beta.1"); if (!Configuration.getGlobalConfiguration().get("AZURE_TELEMETRY_DISABLED", false)) { userAgentBuilder .append(" (") @@ -241,11 +243,24 @@ public KustoManager authenticate(TokenCredential credential, AzureProfile profil List 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/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/fluent/AttachedDatabaseConfigurationsClient.java b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/fluent/AttachedDatabaseConfigurationsClient.java index c09df4dcf14e9..0a2c6df8aa8db 100644 --- a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/fluent/AttachedDatabaseConfigurationsClient.java +++ b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/fluent/AttachedDatabaseConfigurationsClient.java @@ -122,7 +122,7 @@ Response getWithResponse( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing an attached database configuration. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, AttachedDatabaseConfigurationInner> beginCreateOrUpdate( String resourceGroupName, String clusterName, @@ -142,7 +142,7 @@ SyncPoller, AttachedDatabaseConfi * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing an attached database configuration. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, AttachedDatabaseConfigurationInner> beginCreateOrUpdate( String resourceGroupName, String clusterName, @@ -201,7 +201,7 @@ AttachedDatabaseConfigurationInner createOrUpdate( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, Void> beginDelete( String resourceGroupName, String clusterName, String attachedDatabaseConfigurationName); @@ -217,7 +217,7 @@ SyncPoller, Void> beginDelete( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, Void> beginDelete( String resourceGroupName, String clusterName, String attachedDatabaseConfigurationName, Context context); diff --git a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/fluent/ClusterPrincipalAssignmentsClient.java b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/fluent/ClusterPrincipalAssignmentsClient.java index 8d5f90bb17fa9..f702eefea67e5 100644 --- a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/fluent/ClusterPrincipalAssignmentsClient.java +++ b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/fluent/ClusterPrincipalAssignmentsClient.java @@ -95,7 +95,7 @@ Response getWithResponse( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a cluster principal assignment. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, ClusterPrincipalAssignmentInner> beginCreateOrUpdate( String resourceGroupName, String clusterName, @@ -115,7 +115,7 @@ SyncPoller, ClusterPrincipalAssignme * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a cluster principal assignment. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, ClusterPrincipalAssignmentInner> beginCreateOrUpdate( String resourceGroupName, String clusterName, @@ -174,7 +174,7 @@ ClusterPrincipalAssignmentInner createOrUpdate( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, Void> beginDelete( String resourceGroupName, String clusterName, String principalAssignmentName); @@ -190,7 +190,7 @@ SyncPoller, Void> beginDelete( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, Void> beginDelete( String resourceGroupName, String clusterName, String principalAssignmentName, Context context); diff --git a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/fluent/ClustersClient.java b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/fluent/ClustersClient.java index 5a613e8879094..bd72ea969d93d 100644 --- a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/fluent/ClustersClient.java +++ b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/fluent/ClustersClient.java @@ -68,7 +68,7 @@ Response getByResourceGroupWithResponse( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a Kusto cluster. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, ClusterInner> beginCreateOrUpdate( String resourceGroupName, String clusterName, ClusterInner parameters, String ifMatch, String ifNoneMatch); @@ -88,7 +88,7 @@ SyncPoller, ClusterInner> beginCreateOrUpdate( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a Kusto cluster. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, ClusterInner> beginCreateOrUpdate( String resourceGroupName, String clusterName, @@ -168,7 +168,7 @@ ClusterInner createOrUpdate( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a Kusto cluster. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, ClusterInner> beginUpdate( String resourceGroupName, String clusterName, ClusterUpdate parameters, String ifMatch); @@ -186,7 +186,7 @@ SyncPoller, ClusterInner> beginUpdate( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a Kusto cluster. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, ClusterInner> beginUpdate( String resourceGroupName, String clusterName, ClusterUpdate parameters, String ifMatch, Context context); @@ -248,7 +248,7 @@ ClusterInner update( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, Void> beginDelete(String resourceGroupName, String clusterName); /** @@ -262,7 +262,7 @@ ClusterInner update( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, Void> beginDelete(String resourceGroupName, String clusterName, Context context); /** @@ -300,7 +300,7 @@ ClusterInner update( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, Void> beginStop(String resourceGroupName, String clusterName); /** @@ -314,7 +314,7 @@ ClusterInner update( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, Void> beginStop(String resourceGroupName, String clusterName, Context context); /** @@ -352,7 +352,7 @@ ClusterInner update( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, Void> beginStart(String resourceGroupName, String clusterName); /** @@ -366,7 +366,7 @@ ClusterInner update( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, Void> beginStart(String resourceGroupName, String clusterName, Context context); /** @@ -433,7 +433,7 @@ PagedIterable listFollowerDatabases( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, Void> beginDetachFollowerDatabases( String resourceGroupName, String clusterName, FollowerDatabaseDefinitionInner followerDatabaseToRemove); @@ -449,7 +449,7 @@ SyncPoller, Void> beginDetachFollowerDatabases( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, Void> beginDetachFollowerDatabases( String resourceGroupName, String clusterName, @@ -498,7 +498,7 @@ void detachFollowerDatabases( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the response. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, DiagnoseVirtualNetworkResultInner> beginDiagnoseVirtualNetwork(String resourceGroupName, String clusterName); @@ -513,7 +513,7 @@ void detachFollowerDatabases( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the response. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, DiagnoseVirtualNetworkResultInner> beginDiagnoseVirtualNetwork(String resourceGroupName, String clusterName, Context context); @@ -738,7 +738,7 @@ PagedIterable listLanguageExtensions( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, Void> beginAddLanguageExtensions( String resourceGroupName, String clusterName, LanguageExtensionsList languageExtensionsToAdd); @@ -754,7 +754,7 @@ SyncPoller, Void> beginAddLanguageExtensions( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, Void> beginAddLanguageExtensions( String resourceGroupName, String clusterName, LanguageExtensionsList languageExtensionsToAdd, Context context); @@ -798,7 +798,7 @@ void addLanguageExtensions( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, Void> beginRemoveLanguageExtensions( String resourceGroupName, String clusterName, LanguageExtensionsList languageExtensionsToRemove); @@ -814,7 +814,7 @@ SyncPoller, Void> beginRemoveLanguageExtensions( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, Void> beginRemoveLanguageExtensions( String resourceGroupName, String clusterName, diff --git a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/fluent/DataConnectionsClient.java b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/fluent/DataConnectionsClient.java index 3fca0fd0c0fee..cb088a12edae7 100644 --- a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/fluent/DataConnectionsClient.java +++ b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/fluent/DataConnectionsClient.java @@ -62,7 +62,7 @@ PagedIterable listByDatabase( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the list Kusto data connection validation result. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, DataConnectionValidationListResultInner> beginDataConnectionValidation( String resourceGroupName, @@ -83,7 +83,7 @@ PagedIterable listByDatabase( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the list Kusto data connection validation result. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, DataConnectionValidationListResultInner> beginDataConnectionValidation( String resourceGroupName, @@ -215,7 +215,7 @@ Response getWithResponse( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing an data connection. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, DataConnectionInner> beginCreateOrUpdate( String resourceGroupName, String clusterName, @@ -237,7 +237,7 @@ SyncPoller, DataConnectionInner> beginCreateOrUp * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing an data connection. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, DataConnectionInner> beginCreateOrUpdate( String resourceGroupName, String clusterName, @@ -303,7 +303,7 @@ DataConnectionInner createOrUpdate( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing an data connection. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, DataConnectionInner> beginUpdate( String resourceGroupName, String clusterName, @@ -325,7 +325,7 @@ SyncPoller, DataConnectionInner> beginUpdate( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing an data connection. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, DataConnectionInner> beginUpdate( String resourceGroupName, String clusterName, @@ -390,7 +390,7 @@ DataConnectionInner update( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, Void> beginDelete( String resourceGroupName, String clusterName, String databaseName, String dataConnectionName); @@ -407,7 +407,7 @@ SyncPoller, Void> beginDelete( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, Void> beginDelete( String resourceGroupName, String clusterName, String databaseName, String dataConnectionName, Context context); diff --git a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/fluent/DatabasePrincipalAssignmentsClient.java b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/fluent/DatabasePrincipalAssignmentsClient.java index 695e0d04be854..432e8db1bf8b6 100644 --- a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/fluent/DatabasePrincipalAssignmentsClient.java +++ b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/fluent/DatabasePrincipalAssignmentsClient.java @@ -107,7 +107,7 @@ Response getWithResponse( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a database principal assignment. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, DatabasePrincipalAssignmentInner> beginCreateOrUpdate( String resourceGroupName, String clusterName, @@ -129,7 +129,7 @@ SyncPoller, DatabasePrincipalAssign * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a database principal assignment. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, DatabasePrincipalAssignmentInner> beginCreateOrUpdate( String resourceGroupName, String clusterName, @@ -194,7 +194,7 @@ DatabasePrincipalAssignmentInner createOrUpdate( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, Void> beginDelete( String resourceGroupName, String clusterName, String databaseName, String principalAssignmentName); @@ -211,7 +211,7 @@ SyncPoller, Void> beginDelete( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, Void> beginDelete( String resourceGroupName, String clusterName, diff --git a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/fluent/DatabasesClient.java b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/fluent/DatabasesClient.java index f9dd55ea45b75..ee4069b6312c2 100644 --- a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/fluent/DatabasesClient.java +++ b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/fluent/DatabasesClient.java @@ -120,7 +120,7 @@ Response getWithResponse( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a Kusto database. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, DatabaseInner> beginCreateOrUpdate( String resourceGroupName, String clusterName, String databaseName, DatabaseInner parameters); @@ -137,7 +137,7 @@ SyncPoller, DatabaseInner> beginCreateOrUpdate( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a Kusto database. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, DatabaseInner> beginCreateOrUpdate( String resourceGroupName, String clusterName, String databaseName, DatabaseInner parameters, Context context); @@ -186,7 +186,7 @@ DatabaseInner createOrUpdate( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a Kusto database. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, DatabaseInner> beginUpdate( String resourceGroupName, String clusterName, String databaseName, DatabaseInner parameters); @@ -203,7 +203,7 @@ SyncPoller, DatabaseInner> beginUpdate( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a Kusto database. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, DatabaseInner> beginUpdate( String resourceGroupName, String clusterName, String databaseName, DatabaseInner parameters, Context context); @@ -250,7 +250,7 @@ DatabaseInner update( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, Void> beginDelete(String resourceGroupName, String clusterName, String databaseName); /** @@ -265,7 +265,7 @@ DatabaseInner update( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, Void> beginDelete( String resourceGroupName, String clusterName, String databaseName, Context context); diff --git a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/fluent/ManagedPrivateEndpointsClient.java b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/fluent/ManagedPrivateEndpointsClient.java index 51870be55f400..45dfe09307148 100644 --- a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/fluent/ManagedPrivateEndpointsClient.java +++ b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/fluent/ManagedPrivateEndpointsClient.java @@ -120,7 +120,7 @@ Response getWithResponse( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a managed private endpoint. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, ManagedPrivateEndpointInner> beginCreateOrUpdate( String resourceGroupName, String clusterName, @@ -140,7 +140,7 @@ SyncPoller, ManagedPrivateEndpointInner> * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a managed private endpoint. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, ManagedPrivateEndpointInner> beginCreateOrUpdate( String resourceGroupName, String clusterName, @@ -200,7 +200,7 @@ ManagedPrivateEndpointInner createOrUpdate( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a managed private endpoint. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, ManagedPrivateEndpointInner> beginUpdate( String resourceGroupName, String clusterName, @@ -220,7 +220,7 @@ SyncPoller, ManagedPrivateEndpointInner> * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a managed private endpoint. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, ManagedPrivateEndpointInner> beginUpdate( String resourceGroupName, String clusterName, @@ -279,7 +279,7 @@ ManagedPrivateEndpointInner update( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, Void> beginDelete( String resourceGroupName, String clusterName, String managedPrivateEndpointName); @@ -295,7 +295,7 @@ SyncPoller, Void> beginDelete( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, Void> beginDelete( String resourceGroupName, String clusterName, String managedPrivateEndpointName, Context context); diff --git a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/fluent/PrivateEndpointConnectionsClient.java b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/fluent/PrivateEndpointConnectionsClient.java index 9d428aebd388c..09f02082097a6 100644 --- a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/fluent/PrivateEndpointConnectionsClient.java +++ b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/fluent/PrivateEndpointConnectionsClient.java @@ -85,7 +85,7 @@ Response getWithResponse( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return a private endpoint connection. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, PrivateEndpointConnectionInner> beginCreateOrUpdate( String resourceGroupName, String clusterName, @@ -105,7 +105,7 @@ SyncPoller, PrivateEndpointConnection * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return a private endpoint connection. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, PrivateEndpointConnectionInner> beginCreateOrUpdate( String resourceGroupName, String clusterName, @@ -164,7 +164,7 @@ PrivateEndpointConnectionInner createOrUpdate( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, Void> beginDelete( String resourceGroupName, String clusterName, String privateEndpointConnectionName); @@ -180,7 +180,7 @@ SyncPoller, Void> beginDelete( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, Void> beginDelete( String resourceGroupName, String clusterName, String privateEndpointConnectionName, Context context); diff --git a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/fluent/ScriptsClient.java b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/fluent/ScriptsClient.java index 55f1080e0b578..7dde25d11f7eb 100644 --- a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/fluent/ScriptsClient.java +++ b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/fluent/ScriptsClient.java @@ -92,7 +92,7 @@ Response getWithResponse( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a database script. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, ScriptInner> beginCreateOrUpdate( String resourceGroupName, String clusterName, String databaseName, String scriptName, ScriptInner parameters); @@ -110,7 +110,7 @@ SyncPoller, ScriptInner> beginCreateOrUpdate( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a database script. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, ScriptInner> beginCreateOrUpdate( String resourceGroupName, String clusterName, @@ -172,7 +172,7 @@ ScriptInner createOrUpdate( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a database script. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, ScriptInner> beginUpdate( String resourceGroupName, String clusterName, String databaseName, String scriptName, ScriptInner parameters); @@ -190,7 +190,7 @@ SyncPoller, ScriptInner> beginUpdate( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a database script. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, ScriptInner> beginUpdate( String resourceGroupName, String clusterName, @@ -251,7 +251,7 @@ ScriptInner update( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, Void> beginDelete( String resourceGroupName, String clusterName, String databaseName, String scriptName); @@ -268,7 +268,7 @@ SyncPoller, Void> beginDelete( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, Void> beginDelete( String resourceGroupName, String clusterName, String databaseName, String scriptName, Context context); diff --git a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/AttachedDatabaseConfigurationsClientImpl.java b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/AttachedDatabaseConfigurationsClientImpl.java index 0eb819456e00a..cc9cfc46a729c 100644 --- a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/AttachedDatabaseConfigurationsClientImpl.java +++ b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/AttachedDatabaseConfigurationsClientImpl.java @@ -810,7 +810,7 @@ private Mono>> createOrUpdateWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing an attached database configuration. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, AttachedDatabaseConfigurationInner> beginCreateOrUpdateAsync( String resourceGroupName, @@ -827,7 +827,7 @@ private Mono>> createOrUpdateWithResponseAsync( this.client.getHttpPipeline(), AttachedDatabaseConfigurationInner.class, AttachedDatabaseConfigurationInner.class, - Context.NONE); + this.client.getContext()); } /** @@ -843,7 +843,7 @@ private Mono>> createOrUpdateWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing an attached database configuration. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, AttachedDatabaseConfigurationInner> beginCreateOrUpdateAsync( String resourceGroupName, @@ -877,7 +877,7 @@ private Mono>> createOrUpdateWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing an attached database configuration. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, AttachedDatabaseConfigurationInner> beginCreateOrUpdate( String resourceGroupName, @@ -901,7 +901,7 @@ private Mono>> createOrUpdateWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing an attached database configuration. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, AttachedDatabaseConfigurationInner> beginCreateOrUpdate( String resourceGroupName, @@ -1131,14 +1131,15 @@ private Mono>> deleteWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, Void> beginDeleteAsync( String resourceGroupName, String clusterName, String attachedDatabaseConfigurationName) { Mono>> mono = deleteWithResponseAsync(resourceGroupName, clusterName, attachedDatabaseConfigurationName); return this .client - .getLroResult(mono, this.client.getHttpPipeline(), Void.class, Void.class, Context.NONE); + .getLroResult( + mono, this.client.getHttpPipeline(), Void.class, Void.class, this.client.getContext()); } /** @@ -1153,7 +1154,7 @@ private PollerFlux, Void> beginDeleteAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, Void> beginDeleteAsync( String resourceGroupName, String clusterName, String attachedDatabaseConfigurationName, Context context) { context = this.client.mergeContext(context); @@ -1175,7 +1176,7 @@ private PollerFlux, Void> beginDeleteAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, Void> beginDelete( String resourceGroupName, String clusterName, String attachedDatabaseConfigurationName) { return beginDeleteAsync(resourceGroupName, clusterName, attachedDatabaseConfigurationName).getSyncPoller(); @@ -1193,7 +1194,7 @@ public SyncPoller, Void> beginDelete( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, Void> beginDelete( String resourceGroupName, String clusterName, String attachedDatabaseConfigurationName, Context context) { return beginDeleteAsync(resourceGroupName, clusterName, attachedDatabaseConfigurationName, context) diff --git a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/ClusterPrincipalAssignmentsClientImpl.java b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/ClusterPrincipalAssignmentsClientImpl.java index 51d0d74604402..592a55589ff2a 100644 --- a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/ClusterPrincipalAssignmentsClientImpl.java +++ b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/ClusterPrincipalAssignmentsClientImpl.java @@ -647,7 +647,7 @@ private Mono>> createOrUpdateWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a cluster principal assignment. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, ClusterPrincipalAssignmentInner> beginCreateOrUpdateAsync( String resourceGroupName, @@ -663,7 +663,7 @@ private Mono>> createOrUpdateWithResponseAsync( this.client.getHttpPipeline(), ClusterPrincipalAssignmentInner.class, ClusterPrincipalAssignmentInner.class, - Context.NONE); + this.client.getContext()); } /** @@ -679,7 +679,7 @@ private Mono>> createOrUpdateWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a cluster principal assignment. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, ClusterPrincipalAssignmentInner> beginCreateOrUpdateAsync( String resourceGroupName, @@ -713,7 +713,7 @@ private Mono>> createOrUpdateWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a cluster principal assignment. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, ClusterPrincipalAssignmentInner> beginCreateOrUpdate( String resourceGroupName, String clusterName, @@ -736,7 +736,7 @@ public SyncPoller, ClusterPrincipalA * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a cluster principal assignment. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, ClusterPrincipalAssignmentInner> beginCreateOrUpdate( String resourceGroupName, String clusterName, @@ -959,14 +959,15 @@ private Mono>> deleteWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, Void> beginDeleteAsync( String resourceGroupName, String clusterName, String principalAssignmentName) { Mono>> mono = deleteWithResponseAsync(resourceGroupName, clusterName, principalAssignmentName); return this .client - .getLroResult(mono, this.client.getHttpPipeline(), Void.class, Void.class, Context.NONE); + .getLroResult( + mono, this.client.getHttpPipeline(), Void.class, Void.class, this.client.getContext()); } /** @@ -981,7 +982,7 @@ private PollerFlux, Void> beginDeleteAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, Void> beginDeleteAsync( String resourceGroupName, String clusterName, String principalAssignmentName, Context context) { context = this.client.mergeContext(context); @@ -1003,7 +1004,7 @@ private PollerFlux, Void> beginDeleteAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, Void> beginDelete( String resourceGroupName, String clusterName, String principalAssignmentName) { return beginDeleteAsync(resourceGroupName, clusterName, principalAssignmentName).getSyncPoller(); @@ -1021,7 +1022,7 @@ public SyncPoller, Void> beginDelete( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, Void> beginDelete( String resourceGroupName, String clusterName, String principalAssignmentName, Context context) { return beginDeleteAsync(resourceGroupName, clusterName, principalAssignmentName, context).getSyncPoller(); diff --git a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/ClustersClientImpl.java b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/ClustersClientImpl.java index 2f28063728247..34e5109d2425e 100644 --- a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/ClustersClientImpl.java +++ b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/ClustersClientImpl.java @@ -647,7 +647,7 @@ private Mono>> createOrUpdateWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a Kusto cluster. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, ClusterInner> beginCreateOrUpdateAsync( String resourceGroupName, String clusterName, ClusterInner parameters, String ifMatch, String ifNoneMatch) { Mono>> mono = @@ -655,7 +655,7 @@ private PollerFlux, ClusterInner> beginCreateOrUpdateAs return this .client .getLroResult( - mono, this.client.getHttpPipeline(), ClusterInner.class, ClusterInner.class, Context.NONE); + mono, this.client.getHttpPipeline(), ClusterInner.class, ClusterInner.class, this.client.getContext()); } /** @@ -674,7 +674,7 @@ private PollerFlux, ClusterInner> beginCreateOrUpdateAs * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a Kusto cluster. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, ClusterInner> beginCreateOrUpdateAsync( String resourceGroupName, String clusterName, @@ -706,7 +706,7 @@ private PollerFlux, ClusterInner> beginCreateOrUpdateAs * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a Kusto cluster. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, ClusterInner> beginCreateOrUpdate( String resourceGroupName, String clusterName, ClusterInner parameters, String ifMatch, String ifNoneMatch) { return beginCreateOrUpdateAsync(resourceGroupName, clusterName, parameters, ifMatch, ifNoneMatch) @@ -729,7 +729,7 @@ public SyncPoller, ClusterInner> beginCreateOrUpdate( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a Kusto cluster. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, ClusterInner> beginCreateOrUpdate( String resourceGroupName, String clusterName, @@ -1007,7 +1007,7 @@ private Mono>> updateWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a Kusto cluster. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, ClusterInner> beginUpdateAsync( String resourceGroupName, String clusterName, ClusterUpdate parameters, String ifMatch) { Mono>> mono = @@ -1015,7 +1015,7 @@ private PollerFlux, ClusterInner> beginUpdateAsync( return this .client .getLroResult( - mono, this.client.getHttpPipeline(), ClusterInner.class, ClusterInner.class, Context.NONE); + mono, this.client.getHttpPipeline(), ClusterInner.class, ClusterInner.class, this.client.getContext()); } /** @@ -1032,7 +1032,7 @@ private PollerFlux, ClusterInner> beginUpdateAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a Kusto cluster. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, ClusterInner> beginUpdateAsync( String resourceGroupName, String clusterName, ClusterUpdate parameters, String ifMatch, Context context) { context = this.client.mergeContext(context); @@ -1057,7 +1057,7 @@ private PollerFlux, ClusterInner> beginUpdateAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a Kusto cluster. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, ClusterInner> beginUpdate( String resourceGroupName, String clusterName, ClusterUpdate parameters, String ifMatch) { return beginUpdateAsync(resourceGroupName, clusterName, parameters, ifMatch).getSyncPoller(); @@ -1077,7 +1077,7 @@ public SyncPoller, ClusterInner> beginUpdate( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a Kusto cluster. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, ClusterInner> beginUpdate( String resourceGroupName, String clusterName, ClusterUpdate parameters, String ifMatch, Context context) { return beginUpdateAsync(resourceGroupName, clusterName, parameters, ifMatch, context).getSyncPoller(); @@ -1303,12 +1303,13 @@ private Mono>> deleteWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, Void> beginDeleteAsync(String resourceGroupName, String clusterName) { Mono>> mono = deleteWithResponseAsync(resourceGroupName, clusterName); return this .client - .getLroResult(mono, this.client.getHttpPipeline(), Void.class, Void.class, Context.NONE); + .getLroResult( + mono, this.client.getHttpPipeline(), Void.class, Void.class, this.client.getContext()); } /** @@ -1322,7 +1323,7 @@ private PollerFlux, Void> beginDeleteAsync(String resourceGroup * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, Void> beginDeleteAsync( String resourceGroupName, String clusterName, Context context) { context = this.client.mergeContext(context); @@ -1342,7 +1343,7 @@ private PollerFlux, Void> beginDeleteAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, Void> beginDelete(String resourceGroupName, String clusterName) { return beginDeleteAsync(resourceGroupName, clusterName).getSyncPoller(); } @@ -1358,7 +1359,7 @@ public SyncPoller, Void> beginDelete(String resourceGroupName, * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, Void> beginDelete( String resourceGroupName, String clusterName, Context context) { return beginDeleteAsync(resourceGroupName, clusterName, context).getSyncPoller(); @@ -1529,12 +1530,13 @@ private Mono>> stopWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, Void> beginStopAsync(String resourceGroupName, String clusterName) { Mono>> mono = stopWithResponseAsync(resourceGroupName, clusterName); return this .client - .getLroResult(mono, this.client.getHttpPipeline(), Void.class, Void.class, Context.NONE); + .getLroResult( + mono, this.client.getHttpPipeline(), Void.class, Void.class, this.client.getContext()); } /** @@ -1548,7 +1550,7 @@ private PollerFlux, Void> beginStopAsync(String resourceGroupNa * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, Void> beginStopAsync( String resourceGroupName, String clusterName, Context context) { context = this.client.mergeContext(context); @@ -1568,7 +1570,7 @@ private PollerFlux, Void> beginStopAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, Void> beginStop(String resourceGroupName, String clusterName) { return beginStopAsync(resourceGroupName, clusterName).getSyncPoller(); } @@ -1584,7 +1586,7 @@ public SyncPoller, Void> beginStop(String resourceGroupName, St * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, Void> beginStop(String resourceGroupName, String clusterName, Context context) { return beginStopAsync(resourceGroupName, clusterName, context).getSyncPoller(); } @@ -1754,12 +1756,13 @@ private Mono>> startWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, Void> beginStartAsync(String resourceGroupName, String clusterName) { Mono>> mono = startWithResponseAsync(resourceGroupName, clusterName); return this .client - .getLroResult(mono, this.client.getHttpPipeline(), Void.class, Void.class, Context.NONE); + .getLroResult( + mono, this.client.getHttpPipeline(), Void.class, Void.class, this.client.getContext()); } /** @@ -1773,7 +1776,7 @@ private PollerFlux, Void> beginStartAsync(String resourceGroupN * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, Void> beginStartAsync( String resourceGroupName, String clusterName, Context context) { context = this.client.mergeContext(context); @@ -1793,7 +1796,7 @@ private PollerFlux, Void> beginStartAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, Void> beginStart(String resourceGroupName, String clusterName) { return beginStartAsync(resourceGroupName, clusterName).getSyncPoller(); } @@ -1809,7 +1812,7 @@ public SyncPoller, Void> beginStart(String resourceGroupName, S * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, Void> beginStart( String resourceGroupName, String clusterName, Context context) { return beginStartAsync(resourceGroupName, clusterName, context).getSyncPoller(); @@ -2171,14 +2174,15 @@ private Mono>> detachFollowerDatabasesWithResponseAsyn * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, Void> beginDetachFollowerDatabasesAsync( String resourceGroupName, String clusterName, FollowerDatabaseDefinitionInner followerDatabaseToRemove) { Mono>> mono = detachFollowerDatabasesWithResponseAsync(resourceGroupName, clusterName, followerDatabaseToRemove); return this .client - .getLroResult(mono, this.client.getHttpPipeline(), Void.class, Void.class, Context.NONE); + .getLroResult( + mono, this.client.getHttpPipeline(), Void.class, Void.class, this.client.getContext()); } /** @@ -2193,7 +2197,7 @@ private PollerFlux, Void> beginDetachFollowerDatabasesAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, Void> beginDetachFollowerDatabasesAsync( String resourceGroupName, String clusterName, @@ -2218,7 +2222,7 @@ private PollerFlux, Void> beginDetachFollowerDatabasesAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, Void> beginDetachFollowerDatabases( String resourceGroupName, String clusterName, FollowerDatabaseDefinitionInner followerDatabaseToRemove) { return beginDetachFollowerDatabasesAsync(resourceGroupName, clusterName, followerDatabaseToRemove) @@ -2237,7 +2241,7 @@ public SyncPoller, Void> beginDetachFollowerDatabases( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, Void> beginDetachFollowerDatabases( String resourceGroupName, String clusterName, @@ -2429,7 +2433,7 @@ private Mono>> diagnoseVirtualNetworkWithResponseAsync * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the response. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, DiagnoseVirtualNetworkResultInner> beginDiagnoseVirtualNetworkAsync(String resourceGroupName, String clusterName) { Mono>> mono = diagnoseVirtualNetworkWithResponseAsync(resourceGroupName, clusterName); @@ -2440,7 +2444,7 @@ private Mono>> diagnoseVirtualNetworkWithResponseAsync this.client.getHttpPipeline(), DiagnoseVirtualNetworkResultInner.class, DiagnoseVirtualNetworkResultInner.class, - Context.NONE); + this.client.getContext()); } /** @@ -2454,7 +2458,7 @@ private Mono>> diagnoseVirtualNetworkWithResponseAsync * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the response. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, DiagnoseVirtualNetworkResultInner> beginDiagnoseVirtualNetworkAsync(String resourceGroupName, String clusterName, Context context) { context = this.client.mergeContext(context); @@ -2480,7 +2484,7 @@ private Mono>> diagnoseVirtualNetworkWithResponseAsync * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the response. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, DiagnoseVirtualNetworkResultInner> beginDiagnoseVirtualNetwork(String resourceGroupName, String clusterName) { return beginDiagnoseVirtualNetworkAsync(resourceGroupName, clusterName).getSyncPoller(); @@ -2497,7 +2501,7 @@ private Mono>> diagnoseVirtualNetworkWithResponseAsync * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the response. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, DiagnoseVirtualNetworkResultInner> beginDiagnoseVirtualNetwork(String resourceGroupName, String clusterName, Context context) { return beginDiagnoseVirtualNetworkAsync(resourceGroupName, clusterName, context).getSyncPoller(); @@ -3771,14 +3775,15 @@ private Mono>> addLanguageExtensionsWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, Void> beginAddLanguageExtensionsAsync( String resourceGroupName, String clusterName, LanguageExtensionsList languageExtensionsToAdd) { Mono>> mono = addLanguageExtensionsWithResponseAsync(resourceGroupName, clusterName, languageExtensionsToAdd); return this .client - .getLroResult(mono, this.client.getHttpPipeline(), Void.class, Void.class, Context.NONE); + .getLroResult( + mono, this.client.getHttpPipeline(), Void.class, Void.class, this.client.getContext()); } /** @@ -3793,7 +3798,7 @@ private PollerFlux, Void> beginAddLanguageExtensionsAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, Void> beginAddLanguageExtensionsAsync( String resourceGroupName, String clusterName, LanguageExtensionsList languageExtensionsToAdd, Context context) { context = this.client.mergeContext(context); @@ -3815,7 +3820,7 @@ private PollerFlux, Void> beginAddLanguageExtensionsAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, Void> beginAddLanguageExtensions( String resourceGroupName, String clusterName, LanguageExtensionsList languageExtensionsToAdd) { return beginAddLanguageExtensionsAsync(resourceGroupName, clusterName, languageExtensionsToAdd).getSyncPoller(); @@ -3833,7 +3838,7 @@ public SyncPoller, Void> beginAddLanguageExtensions( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, Void> beginAddLanguageExtensions( String resourceGroupName, String clusterName, LanguageExtensionsList languageExtensionsToAdd, Context context) { return beginAddLanguageExtensionsAsync(resourceGroupName, clusterName, languageExtensionsToAdd, context) @@ -4040,14 +4045,15 @@ private Mono>> removeLanguageExtensionsWithResponseAsy * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, Void> beginRemoveLanguageExtensionsAsync( String resourceGroupName, String clusterName, LanguageExtensionsList languageExtensionsToRemove) { Mono>> mono = removeLanguageExtensionsWithResponseAsync(resourceGroupName, clusterName, languageExtensionsToRemove); return this .client - .getLroResult(mono, this.client.getHttpPipeline(), Void.class, Void.class, Context.NONE); + .getLroResult( + mono, this.client.getHttpPipeline(), Void.class, Void.class, this.client.getContext()); } /** @@ -4062,7 +4068,7 @@ private PollerFlux, Void> beginRemoveLanguageExtensionsAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, Void> beginRemoveLanguageExtensionsAsync( String resourceGroupName, String clusterName, @@ -4088,7 +4094,7 @@ private PollerFlux, Void> beginRemoveLanguageExtensionsAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, Void> beginRemoveLanguageExtensions( String resourceGroupName, String clusterName, LanguageExtensionsList languageExtensionsToRemove) { return beginRemoveLanguageExtensionsAsync(resourceGroupName, clusterName, languageExtensionsToRemove) @@ -4107,7 +4113,7 @@ public SyncPoller, Void> beginRemoveLanguageExtensions( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, Void> beginRemoveLanguageExtensions( String resourceGroupName, String clusterName, diff --git a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/DataConnectionsClientImpl.java b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/DataConnectionsClientImpl.java index a75c93d33a5a9..f9e71922f2a69 100644 --- a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/DataConnectionsClientImpl.java +++ b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/DataConnectionsClientImpl.java @@ -511,7 +511,7 @@ private Mono>> dataConnectionValidationWithResponseAsy * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the list Kusto data connection validation result. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, DataConnectionValidationListResultInner> beginDataConnectionValidationAsync( String resourceGroupName, @@ -527,7 +527,7 @@ private Mono>> dataConnectionValidationWithResponseAsy this.client.getHttpPipeline(), DataConnectionValidationListResultInner.class, DataConnectionValidationListResultInner.class, - Context.NONE); + this.client.getContext()); } /** @@ -543,7 +543,7 @@ private Mono>> dataConnectionValidationWithResponseAsy * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the list Kusto data connection validation result. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, DataConnectionValidationListResultInner> beginDataConnectionValidationAsync( String resourceGroupName, @@ -577,7 +577,7 @@ private Mono>> dataConnectionValidationWithResponseAsy * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the list Kusto data connection validation result. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, DataConnectionValidationListResultInner> beginDataConnectionValidation( String resourceGroupName, @@ -601,7 +601,7 @@ private Mono>> dataConnectionValidationWithResponseAsy * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the list Kusto data connection validation result. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, DataConnectionValidationListResultInner> beginDataConnectionValidation( String resourceGroupName, @@ -1232,7 +1232,7 @@ private Mono>> createOrUpdateWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing an data connection. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, DataConnectionInner> beginCreateOrUpdateAsync( String resourceGroupName, String clusterName, @@ -1249,7 +1249,7 @@ private PollerFlux, DataConnectionInner> beginCr this.client.getHttpPipeline(), DataConnectionInner.class, DataConnectionInner.class, - Context.NONE); + this.client.getContext()); } /** @@ -1266,7 +1266,7 @@ private PollerFlux, DataConnectionInner> beginCr * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing an data connection. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, DataConnectionInner> beginCreateOrUpdateAsync( String resourceGroupName, String clusterName, @@ -1297,7 +1297,7 @@ private PollerFlux, DataConnectionInner> beginCr * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing an data connection. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, DataConnectionInner> beginCreateOrUpdate( String resourceGroupName, String clusterName, @@ -1322,7 +1322,7 @@ public SyncPoller, DataConnectionInner> beginCre * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing an data connection. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, DataConnectionInner> beginCreateOrUpdate( String resourceGroupName, String clusterName, @@ -1591,7 +1591,7 @@ private Mono>> updateWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing an data connection. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, DataConnectionInner> beginUpdateAsync( String resourceGroupName, String clusterName, @@ -1607,7 +1607,7 @@ private PollerFlux, DataConnectionInner> beginUp this.client.getHttpPipeline(), DataConnectionInner.class, DataConnectionInner.class, - Context.NONE); + this.client.getContext()); } /** @@ -1624,7 +1624,7 @@ private PollerFlux, DataConnectionInner> beginUp * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing an data connection. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, DataConnectionInner> beginUpdateAsync( String resourceGroupName, String clusterName, @@ -1655,7 +1655,7 @@ private PollerFlux, DataConnectionInner> beginUp * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing an data connection. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, DataConnectionInner> beginUpdate( String resourceGroupName, String clusterName, @@ -1680,7 +1680,7 @@ public SyncPoller, DataConnectionInner> beginUpd * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing an data connection. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, DataConnectionInner> beginUpdate( String resourceGroupName, String clusterName, @@ -1921,14 +1921,15 @@ private Mono>> deleteWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, Void> beginDeleteAsync( String resourceGroupName, String clusterName, String databaseName, String dataConnectionName) { Mono>> mono = deleteWithResponseAsync(resourceGroupName, clusterName, databaseName, dataConnectionName); return this .client - .getLroResult(mono, this.client.getHttpPipeline(), Void.class, Void.class, Context.NONE); + .getLroResult( + mono, this.client.getHttpPipeline(), Void.class, Void.class, this.client.getContext()); } /** @@ -1944,7 +1945,7 @@ private PollerFlux, Void> beginDeleteAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, Void> beginDeleteAsync( String resourceGroupName, String clusterName, String databaseName, String dataConnectionName, Context context) { context = this.client.mergeContext(context); @@ -1967,7 +1968,7 @@ private PollerFlux, Void> beginDeleteAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, Void> beginDelete( String resourceGroupName, String clusterName, String databaseName, String dataConnectionName) { return beginDeleteAsync(resourceGroupName, clusterName, databaseName, dataConnectionName).getSyncPoller(); @@ -1986,7 +1987,7 @@ public SyncPoller, Void> beginDelete( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, Void> beginDelete( String resourceGroupName, String clusterName, String databaseName, String dataConnectionName, Context context) { return beginDeleteAsync(resourceGroupName, clusterName, databaseName, dataConnectionName, context) diff --git a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/DatabasePrincipalAssignmentsClientImpl.java b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/DatabasePrincipalAssignmentsClientImpl.java index 5c947acc4666b..77132ec35494e 100644 --- a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/DatabasePrincipalAssignmentsClientImpl.java +++ b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/DatabasePrincipalAssignmentsClientImpl.java @@ -708,7 +708,7 @@ private Mono>> createOrUpdateWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a database principal assignment. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, DatabasePrincipalAssignmentInner> beginCreateOrUpdateAsync( String resourceGroupName, @@ -726,7 +726,7 @@ private Mono>> createOrUpdateWithResponseAsync( this.client.getHttpPipeline(), DatabasePrincipalAssignmentInner.class, DatabasePrincipalAssignmentInner.class, - Context.NONE); + this.client.getContext()); } /** @@ -743,7 +743,7 @@ private Mono>> createOrUpdateWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a database principal assignment. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, DatabasePrincipalAssignmentInner> beginCreateOrUpdateAsync( String resourceGroupName, @@ -779,7 +779,7 @@ private Mono>> createOrUpdateWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a database principal assignment. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, DatabasePrincipalAssignmentInner> beginCreateOrUpdate( String resourceGroupName, @@ -806,7 +806,7 @@ private Mono>> createOrUpdateWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a database principal assignment. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, DatabasePrincipalAssignmentInner> beginCreateOrUpdate( String resourceGroupName, @@ -1059,14 +1059,15 @@ private Mono>> deleteWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, Void> beginDeleteAsync( String resourceGroupName, String clusterName, String databaseName, String principalAssignmentName) { Mono>> mono = deleteWithResponseAsync(resourceGroupName, clusterName, databaseName, principalAssignmentName); return this .client - .getLroResult(mono, this.client.getHttpPipeline(), Void.class, Void.class, Context.NONE); + .getLroResult( + mono, this.client.getHttpPipeline(), Void.class, Void.class, this.client.getContext()); } /** @@ -1082,7 +1083,7 @@ private PollerFlux, Void> beginDeleteAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, Void> beginDeleteAsync( String resourceGroupName, String clusterName, @@ -1109,7 +1110,7 @@ private PollerFlux, Void> beginDeleteAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, Void> beginDelete( String resourceGroupName, String clusterName, String databaseName, String principalAssignmentName) { return beginDeleteAsync(resourceGroupName, clusterName, databaseName, principalAssignmentName).getSyncPoller(); @@ -1128,7 +1129,7 @@ public SyncPoller, Void> beginDelete( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, Void> beginDelete( String resourceGroupName, String clusterName, diff --git a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/DatabasesClientImpl.java b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/DatabasesClientImpl.java index ec3af72ed51e6..b4d7c582d2e30 100644 --- a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/DatabasesClientImpl.java +++ b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/DatabasesClientImpl.java @@ -846,7 +846,7 @@ private Mono>> createOrUpdateWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a Kusto database. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, DatabaseInner> beginCreateOrUpdateAsync( String resourceGroupName, String clusterName, String databaseName, DatabaseInner parameters) { Mono>> mono = @@ -854,7 +854,11 @@ private PollerFlux, DatabaseInner> beginCreateOrUpdate return this .client .getLroResult( - mono, this.client.getHttpPipeline(), DatabaseInner.class, DatabaseInner.class, Context.NONE); + mono, + this.client.getHttpPipeline(), + DatabaseInner.class, + DatabaseInner.class, + this.client.getContext()); } /** @@ -870,7 +874,7 @@ private PollerFlux, DatabaseInner> beginCreateOrUpdate * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a Kusto database. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, DatabaseInner> beginCreateOrUpdateAsync( String resourceGroupName, String clusterName, String databaseName, DatabaseInner parameters, Context context) { context = this.client.mergeContext(context); @@ -894,7 +898,7 @@ private PollerFlux, DatabaseInner> beginCreateOrUpdate * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a Kusto database. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, DatabaseInner> beginCreateOrUpdate( String resourceGroupName, String clusterName, String databaseName, DatabaseInner parameters) { return beginCreateOrUpdateAsync(resourceGroupName, clusterName, databaseName, parameters).getSyncPoller(); @@ -913,7 +917,7 @@ public SyncPoller, DatabaseInner> beginCreateOrUpdate( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a Kusto database. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, DatabaseInner> beginCreateOrUpdate( String resourceGroupName, String clusterName, String databaseName, DatabaseInner parameters, Context context) { return beginCreateOrUpdateAsync(resourceGroupName, clusterName, databaseName, parameters, context) @@ -1128,7 +1132,7 @@ private Mono>> updateWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a Kusto database. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, DatabaseInner> beginUpdateAsync( String resourceGroupName, String clusterName, String databaseName, DatabaseInner parameters) { Mono>> mono = @@ -1136,7 +1140,11 @@ private PollerFlux, DatabaseInner> beginUpdateAsync( return this .client .getLroResult( - mono, this.client.getHttpPipeline(), DatabaseInner.class, DatabaseInner.class, Context.NONE); + mono, + this.client.getHttpPipeline(), + DatabaseInner.class, + DatabaseInner.class, + this.client.getContext()); } /** @@ -1152,7 +1160,7 @@ private PollerFlux, DatabaseInner> beginUpdateAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a Kusto database. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, DatabaseInner> beginUpdateAsync( String resourceGroupName, String clusterName, String databaseName, DatabaseInner parameters, Context context) { context = this.client.mergeContext(context); @@ -1176,7 +1184,7 @@ private PollerFlux, DatabaseInner> beginUpdateAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a Kusto database. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, DatabaseInner> beginUpdate( String resourceGroupName, String clusterName, String databaseName, DatabaseInner parameters) { return beginUpdateAsync(resourceGroupName, clusterName, databaseName, parameters).getSyncPoller(); @@ -1195,7 +1203,7 @@ public SyncPoller, DatabaseInner> beginUpdate( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a Kusto database. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, DatabaseInner> beginUpdate( String resourceGroupName, String clusterName, String databaseName, DatabaseInner parameters, Context context) { return beginUpdateAsync(resourceGroupName, clusterName, databaseName, parameters, context).getSyncPoller(); @@ -1394,13 +1402,14 @@ private Mono>> deleteWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, Void> beginDeleteAsync( String resourceGroupName, String clusterName, String databaseName) { Mono>> mono = deleteWithResponseAsync(resourceGroupName, clusterName, databaseName); return this .client - .getLroResult(mono, this.client.getHttpPipeline(), Void.class, Void.class, Context.NONE); + .getLroResult( + mono, this.client.getHttpPipeline(), Void.class, Void.class, this.client.getContext()); } /** @@ -1415,7 +1424,7 @@ private PollerFlux, Void> beginDeleteAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, Void> beginDeleteAsync( String resourceGroupName, String clusterName, String databaseName, Context context) { context = this.client.mergeContext(context); @@ -1437,7 +1446,7 @@ private PollerFlux, Void> beginDeleteAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, Void> beginDelete( String resourceGroupName, String clusterName, String databaseName) { return beginDeleteAsync(resourceGroupName, clusterName, databaseName).getSyncPoller(); @@ -1455,7 +1464,7 @@ public SyncPoller, Void> beginDelete( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, Void> beginDelete( String resourceGroupName, String clusterName, String databaseName, Context context) { return beginDeleteAsync(resourceGroupName, clusterName, databaseName, context).getSyncPoller(); diff --git a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/ManagedPrivateEndpointsClientImpl.java b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/ManagedPrivateEndpointsClientImpl.java index a68ee57a0a816..c10784cc78813 100644 --- a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/ManagedPrivateEndpointsClientImpl.java +++ b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/ManagedPrivateEndpointsClientImpl.java @@ -823,7 +823,7 @@ private Mono>> createOrUpdateWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a managed private endpoint. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, ManagedPrivateEndpointInner> beginCreateOrUpdateAsync( String resourceGroupName, String clusterName, @@ -838,7 +838,7 @@ private PollerFlux, ManagedPrivateEndpoi this.client.getHttpPipeline(), ManagedPrivateEndpointInner.class, ManagedPrivateEndpointInner.class, - Context.NONE); + this.client.getContext()); } /** @@ -854,7 +854,7 @@ private PollerFlux, ManagedPrivateEndpoi * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a managed private endpoint. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, ManagedPrivateEndpointInner> beginCreateOrUpdateAsync( String resourceGroupName, String clusterName, @@ -887,7 +887,7 @@ private PollerFlux, ManagedPrivateEndpoi * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a managed private endpoint. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, ManagedPrivateEndpointInner> beginCreateOrUpdate( String resourceGroupName, String clusterName, @@ -910,7 +910,7 @@ public SyncPoller, ManagedPrivateEndpoin * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a managed private endpoint. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, ManagedPrivateEndpointInner> beginCreateOrUpdate( String resourceGroupName, String clusterName, @@ -1157,7 +1157,7 @@ private Mono>> updateWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a managed private endpoint. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, ManagedPrivateEndpointInner> beginUpdateAsync( String resourceGroupName, String clusterName, @@ -1172,7 +1172,7 @@ private PollerFlux, ManagedPrivateEndpoi this.client.getHttpPipeline(), ManagedPrivateEndpointInner.class, ManagedPrivateEndpointInner.class, - Context.NONE); + this.client.getContext()); } /** @@ -1188,7 +1188,7 @@ private PollerFlux, ManagedPrivateEndpoi * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a managed private endpoint. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, ManagedPrivateEndpointInner> beginUpdateAsync( String resourceGroupName, String clusterName, @@ -1220,7 +1220,7 @@ private PollerFlux, ManagedPrivateEndpoi * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a managed private endpoint. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, ManagedPrivateEndpointInner> beginUpdate( String resourceGroupName, String clusterName, @@ -1242,7 +1242,7 @@ public SyncPoller, ManagedPrivateEndpoin * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a managed private endpoint. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, ManagedPrivateEndpointInner> beginUpdate( String resourceGroupName, String clusterName, @@ -1466,14 +1466,15 @@ private Mono>> deleteWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, Void> beginDeleteAsync( String resourceGroupName, String clusterName, String managedPrivateEndpointName) { Mono>> mono = deleteWithResponseAsync(resourceGroupName, clusterName, managedPrivateEndpointName); return this .client - .getLroResult(mono, this.client.getHttpPipeline(), Void.class, Void.class, Context.NONE); + .getLroResult( + mono, this.client.getHttpPipeline(), Void.class, Void.class, this.client.getContext()); } /** @@ -1488,7 +1489,7 @@ private PollerFlux, Void> beginDeleteAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, Void> beginDeleteAsync( String resourceGroupName, String clusterName, String managedPrivateEndpointName, Context context) { context = this.client.mergeContext(context); @@ -1510,7 +1511,7 @@ private PollerFlux, Void> beginDeleteAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, Void> beginDelete( String resourceGroupName, String clusterName, String managedPrivateEndpointName) { return beginDeleteAsync(resourceGroupName, clusterName, managedPrivateEndpointName).getSyncPoller(); @@ -1528,7 +1529,7 @@ public SyncPoller, Void> beginDelete( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, Void> beginDelete( String resourceGroupName, String clusterName, String managedPrivateEndpointName, Context context) { return beginDeleteAsync(resourceGroupName, clusterName, managedPrivateEndpointName, context).getSyncPoller(); diff --git a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/PrivateEndpointConnectionsClientImpl.java b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/PrivateEndpointConnectionsClientImpl.java index 2e0757f77cd5c..8dafe88655575 100644 --- a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/PrivateEndpointConnectionsClientImpl.java +++ b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/PrivateEndpointConnectionsClientImpl.java @@ -613,7 +613,7 @@ private Mono>> createOrUpdateWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return a private endpoint connection. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, PrivateEndpointConnectionInner> beginCreateOrUpdateAsync( String resourceGroupName, @@ -629,7 +629,7 @@ private Mono>> createOrUpdateWithResponseAsync( this.client.getHttpPipeline(), PrivateEndpointConnectionInner.class, PrivateEndpointConnectionInner.class, - Context.NONE); + this.client.getContext()); } /** @@ -645,7 +645,7 @@ private Mono>> createOrUpdateWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return a private endpoint connection. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, PrivateEndpointConnectionInner> beginCreateOrUpdateAsync( String resourceGroupName, @@ -679,7 +679,7 @@ private Mono>> createOrUpdateWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return a private endpoint connection. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, PrivateEndpointConnectionInner> beginCreateOrUpdate( String resourceGroupName, String clusterName, @@ -702,7 +702,7 @@ public SyncPoller, PrivateEndpointCon * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return a private endpoint connection. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, PrivateEndpointConnectionInner> beginCreateOrUpdate( String resourceGroupName, String clusterName, @@ -929,14 +929,15 @@ private Mono>> deleteWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, Void> beginDeleteAsync( String resourceGroupName, String clusterName, String privateEndpointConnectionName) { Mono>> mono = deleteWithResponseAsync(resourceGroupName, clusterName, privateEndpointConnectionName); return this .client - .getLroResult(mono, this.client.getHttpPipeline(), Void.class, Void.class, Context.NONE); + .getLroResult( + mono, this.client.getHttpPipeline(), Void.class, Void.class, this.client.getContext()); } /** @@ -951,7 +952,7 @@ private PollerFlux, Void> beginDeleteAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, Void> beginDeleteAsync( String resourceGroupName, String clusterName, String privateEndpointConnectionName, Context context) { context = this.client.mergeContext(context); @@ -973,7 +974,7 @@ private PollerFlux, Void> beginDeleteAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, Void> beginDelete( String resourceGroupName, String clusterName, String privateEndpointConnectionName) { return beginDeleteAsync(resourceGroupName, clusterName, privateEndpointConnectionName).getSyncPoller(); @@ -991,7 +992,7 @@ public SyncPoller, Void> beginDelete( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, Void> beginDelete( String resourceGroupName, String clusterName, String privateEndpointConnectionName, Context context) { return beginDeleteAsync(resourceGroupName, clusterName, privateEndpointConnectionName, context).getSyncPoller(); diff --git a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/ScriptsClientImpl.java b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/ScriptsClientImpl.java index 9887fde4305f2..d8060ec2fe4b4 100644 --- a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/ScriptsClientImpl.java +++ b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/ScriptsClientImpl.java @@ -679,7 +679,7 @@ private Mono>> createOrUpdateWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a database script. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, ScriptInner> beginCreateOrUpdateAsync( String resourceGroupName, String clusterName, String databaseName, String scriptName, ScriptInner parameters) { Mono>> mono = @@ -687,7 +687,7 @@ private PollerFlux, ScriptInner> beginCreateOrUpdateAsyn return this .client .getLroResult( - mono, this.client.getHttpPipeline(), ScriptInner.class, ScriptInner.class, Context.NONE); + mono, this.client.getHttpPipeline(), ScriptInner.class, ScriptInner.class, this.client.getContext()); } /** @@ -704,7 +704,7 @@ private PollerFlux, ScriptInner> beginCreateOrUpdateAsyn * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a database script. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, ScriptInner> beginCreateOrUpdateAsync( String resourceGroupName, String clusterName, @@ -735,7 +735,7 @@ private PollerFlux, ScriptInner> beginCreateOrUpdateAsyn * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a database script. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, ScriptInner> beginCreateOrUpdate( String resourceGroupName, String clusterName, String databaseName, String scriptName, ScriptInner parameters) { return beginCreateOrUpdateAsync(resourceGroupName, clusterName, databaseName, scriptName, parameters) @@ -756,7 +756,7 @@ public SyncPoller, ScriptInner> beginCreateOrUpdate( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a database script. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, ScriptInner> beginCreateOrUpdate( String resourceGroupName, String clusterName, @@ -1007,7 +1007,7 @@ private Mono>> updateWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a database script. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, ScriptInner> beginUpdateAsync( String resourceGroupName, String clusterName, String databaseName, String scriptName, ScriptInner parameters) { Mono>> mono = @@ -1015,7 +1015,7 @@ private PollerFlux, ScriptInner> beginUpdateAsync( return this .client .getLroResult( - mono, this.client.getHttpPipeline(), ScriptInner.class, ScriptInner.class, Context.NONE); + mono, this.client.getHttpPipeline(), ScriptInner.class, ScriptInner.class, this.client.getContext()); } /** @@ -1032,7 +1032,7 @@ private PollerFlux, ScriptInner> beginUpdateAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a database script. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, ScriptInner> beginUpdateAsync( String resourceGroupName, String clusterName, @@ -1062,7 +1062,7 @@ private PollerFlux, ScriptInner> beginUpdateAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a database script. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, ScriptInner> beginUpdate( String resourceGroupName, String clusterName, String databaseName, String scriptName, ScriptInner parameters) { return beginUpdateAsync(resourceGroupName, clusterName, databaseName, scriptName, parameters).getSyncPoller(); @@ -1082,7 +1082,7 @@ public SyncPoller, ScriptInner> beginUpdate( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return class representing a database script. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, ScriptInner> beginUpdate( String resourceGroupName, String clusterName, @@ -1312,14 +1312,15 @@ private Mono>> deleteWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, Void> beginDeleteAsync( String resourceGroupName, String clusterName, String databaseName, String scriptName) { Mono>> mono = deleteWithResponseAsync(resourceGroupName, clusterName, databaseName, scriptName); return this .client - .getLroResult(mono, this.client.getHttpPipeline(), Void.class, Void.class, Context.NONE); + .getLroResult( + mono, this.client.getHttpPipeline(), Void.class, Void.class, this.client.getContext()); } /** @@ -1335,7 +1336,7 @@ private PollerFlux, Void> beginDeleteAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, Void> beginDeleteAsync( String resourceGroupName, String clusterName, String databaseName, String scriptName, Context context) { context = this.client.mergeContext(context); @@ -1358,7 +1359,7 @@ private PollerFlux, Void> beginDeleteAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, Void> beginDelete( String resourceGroupName, String clusterName, String databaseName, String scriptName) { return beginDeleteAsync(resourceGroupName, clusterName, databaseName, scriptName).getSyncPoller(); @@ -1377,7 +1378,7 @@ public SyncPoller, Void> beginDelete( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, Void> beginDelete( String resourceGroupName, String clusterName, String databaseName, String scriptName, Context context) { return beginDeleteAsync(resourceGroupName, clusterName, databaseName, scriptName, context).getSyncPoller(); diff --git a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/models/AttachedDatabaseConfigurationsCheckNameRequest.java b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/models/AttachedDatabaseConfigurationsCheckNameRequest.java index 35495f219fb88..6b6d24607ec0b 100644 --- a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/models/AttachedDatabaseConfigurationsCheckNameRequest.java +++ b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/models/AttachedDatabaseConfigurationsCheckNameRequest.java @@ -26,7 +26,7 @@ public final class AttachedDatabaseConfigurationsCheckNameRequest { * Microsoft.Kusto/clusters/attachedDatabaseConfigurations. */ @JsonProperty(value = "type", required = true) - private String type; + private String type = "Microsoft.Kusto/clusters/attachedDatabaseConfigurations"; /** Creates an instance of AttachedDatabaseConfigurationsCheckNameRequest class. */ public AttachedDatabaseConfigurationsCheckNameRequest() { diff --git a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/models/ClusterCheckNameRequest.java b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/models/ClusterCheckNameRequest.java index fd0734d7cebef..8a4ed061419a1 100644 --- a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/models/ClusterCheckNameRequest.java +++ b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/models/ClusterCheckNameRequest.java @@ -24,7 +24,7 @@ public final class ClusterCheckNameRequest { * The type of resource, Microsoft.Kusto/clusters. */ @JsonProperty(value = "type", required = true) - private String type; + private String type = "Microsoft.Kusto/clusters"; /** Creates an instance of ClusterCheckNameRequest class. */ public ClusterCheckNameRequest() { diff --git a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/models/ClusterPrincipalAssignmentCheckNameRequest.java b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/models/ClusterPrincipalAssignmentCheckNameRequest.java index 9b558a1395616..541c434a9cd0e 100644 --- a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/models/ClusterPrincipalAssignmentCheckNameRequest.java +++ b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/models/ClusterPrincipalAssignmentCheckNameRequest.java @@ -24,7 +24,7 @@ public final class ClusterPrincipalAssignmentCheckNameRequest { * The type of resource, Microsoft.Kusto/clusters/principalAssignments. */ @JsonProperty(value = "type", required = true) - private String type; + private String type = "Microsoft.Kusto/clusters/principalAssignments"; /** Creates an instance of ClusterPrincipalAssignmentCheckNameRequest class. */ public ClusterPrincipalAssignmentCheckNameRequest() { diff --git a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/models/DataConnectionCheckNameRequest.java b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/models/DataConnectionCheckNameRequest.java index fa24170e04905..5547cb269063d 100644 --- a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/models/DataConnectionCheckNameRequest.java +++ b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/models/DataConnectionCheckNameRequest.java @@ -25,7 +25,7 @@ public final class DataConnectionCheckNameRequest { * Microsoft.Kusto/clusters/databases/dataConnections. */ @JsonProperty(value = "type", required = true) - private String type; + private String type = "Microsoft.Kusto/clusters/databases/dataConnections"; /** Creates an instance of DataConnectionCheckNameRequest class. */ public DataConnectionCheckNameRequest() { diff --git a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/models/DatabasePrincipalAssignmentCheckNameRequest.java b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/models/DatabasePrincipalAssignmentCheckNameRequest.java index 786a11f2d2b44..d32142c885946 100644 --- a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/models/DatabasePrincipalAssignmentCheckNameRequest.java +++ b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/models/DatabasePrincipalAssignmentCheckNameRequest.java @@ -25,7 +25,7 @@ public final class DatabasePrincipalAssignmentCheckNameRequest { * Microsoft.Kusto/clusters/databases/principalAssignments. */ @JsonProperty(value = "type", required = true) - private String type; + private String type = "Microsoft.Kusto/clusters/databases/principalAssignments"; /** Creates an instance of DatabasePrincipalAssignmentCheckNameRequest class. */ public DatabasePrincipalAssignmentCheckNameRequest() { diff --git a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/models/ManagedPrivateEndpointsCheckNameRequest.java b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/models/ManagedPrivateEndpointsCheckNameRequest.java index 230bbbc001332..4acc1fe5a7560 100644 --- a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/models/ManagedPrivateEndpointsCheckNameRequest.java +++ b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/models/ManagedPrivateEndpointsCheckNameRequest.java @@ -25,7 +25,7 @@ public final class ManagedPrivateEndpointsCheckNameRequest { * Microsoft.Kusto/clusters/managedPrivateEndpoints. */ @JsonProperty(value = "type", required = true) - private String type; + private String type = "Microsoft.Kusto/clusters/managedPrivateEndpoints"; /** Creates an instance of ManagedPrivateEndpointsCheckNameRequest class. */ public ManagedPrivateEndpointsCheckNameRequest() { diff --git a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/models/ScriptCheckNameRequest.java b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/models/ScriptCheckNameRequest.java index d0ce5fa255af0..921fe69cd26ef 100644 --- a/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/models/ScriptCheckNameRequest.java +++ b/sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/models/ScriptCheckNameRequest.java @@ -24,7 +24,7 @@ public final class ScriptCheckNameRequest { * The type of resource, Microsoft.Kusto/clusters/databases/scripts. */ @JsonProperty(value = "type", required = true) - private String type; + private String type = "Microsoft.Kusto/clusters/databases/scripts"; /** Creates an instance of ScriptCheckNameRequest class. */ public ScriptCheckNameRequest() {