From 1d48fa387acb9c206003391b7611a469024ad97a Mon Sep 17 00:00:00 2001 From: SDKAuto Date: Fri, 26 Nov 2021 07:42:03 +0000 Subject: [PATCH] CodeGen from PR 16886 in Azure/azure-rest-api-specs Merge c00e5ce96ae9732e967d50cb3c6e1e73e5abf34e into 37d690709ce4639bd0aafe7f4a5f5856f2bef624 --- .../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 | 16 ++--- ...ClusterPrincipalAssignmentsClientImpl.java | 16 ++--- .../implementation/ClustersClientImpl.java | 72 +++++++++---------- .../DataConnectionsClientImpl.java | 32 ++++----- ...atabasePrincipalAssignmentsClientImpl.java | 16 ++--- .../implementation/DatabasesClientImpl.java | 24 +++---- .../ManagedPrivateEndpointsClientImpl.java | 24 +++---- .../PrivateEndpointConnectionsClientImpl.java | 16 ++--- .../implementation/ScriptsClientImpl.java | 24 +++---- ...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, 208 insertions(+), 191 deletions(-) diff --git a/sdk/kusto/azure-resourcemanager-kusto/CHANGELOG.md b/sdk/kusto/azure-resourcemanager-kusto/CHANGELOG.md index 0ef14a22d29a..f8b40fb8b6d7 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 (2021-11-26) + +- 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 a64bd7823629..ac19ffe65da3 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 45eff1c72dc0..47c518418805 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 c09df4dcf14e..0a2c6df8aa8d 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 8d5f90bb17fa..f702eefea67e 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 5a613e887909..bd72ea969d93 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 3fca0fd0c0fe..cb088a12edae 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 695e0d04be85..432e8db1bf8b 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 f9dd55ea45b7..ee4069b6312c 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 51870be55f40..45dfe0930714 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 9d428aebd388..09f02082097a 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 55f1080e0b57..7dde25d11f7e 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 0eb819456e00..b6f52154ec59 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, @@ -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,7 +1131,7 @@ 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 = @@ -1153,7 +1153,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 +1175,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 +1193,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 51d0d7460440..6b225f4f14e9 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, @@ -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,7 +959,7 @@ 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 = @@ -981,7 +981,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 +1003,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 +1021,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 2f2806372824..6be83da557e8 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 = @@ -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 = @@ -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,7 +1303,7 @@ 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 @@ -1322,7 +1322,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 +1342,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 +1358,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,7 +1529,7 @@ 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 @@ -1548,7 +1548,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 +1568,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 +1584,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,7 +1754,7 @@ 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 @@ -1773,7 +1773,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 +1793,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 +1809,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,7 +2171,7 @@ 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 = @@ -2193,7 +2193,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 +2218,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 +2237,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 +2429,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); @@ -2454,7 +2454,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 +2480,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 +2497,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,7 +3771,7 @@ 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 = @@ -3793,7 +3793,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 +3815,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 +3833,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,7 +4040,7 @@ 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 = @@ -4062,7 +4062,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 +4088,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 +4107,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 a75c93d33a5a..3a7df2e44285 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, @@ -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, @@ -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, @@ -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,7 +1921,7 @@ 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 = @@ -1944,7 +1944,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 +1967,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 +1986,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 5c947acc4666..4774ba8a6144 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, @@ -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,7 +1059,7 @@ 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 = @@ -1082,7 +1082,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 +1109,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 +1128,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 ec3af72ed51e..f861f06cd62c 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 = @@ -870,7 +870,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 +894,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 +913,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 +1128,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 = @@ -1152,7 +1152,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 +1176,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 +1195,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,7 +1394,7 @@ 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); @@ -1415,7 +1415,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 +1437,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 +1455,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 a68ee57a0a81..37ea79110cfe 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, @@ -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, @@ -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,7 +1466,7 @@ 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 = @@ -1488,7 +1488,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 +1510,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 +1528,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 2e0757f77cd5..4d93a9443133 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, @@ -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,7 +929,7 @@ 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 = @@ -951,7 +951,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 +973,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 +991,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 9887fde4305f..59b4ea763f98 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 = @@ -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 = @@ -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,7 +1312,7 @@ 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 = @@ -1335,7 +1335,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 +1358,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 +1377,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 35495f219fb8..6b6d24607ec0 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 fd0734d7cebe..8a4ed061419a 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 9b558a139561..541c434a9cd0 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 fa24170e0490..5547cb269063 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 786a11f2d2b4..d32142c88594 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 230bbbc00133..4acc1fe5a756 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 d0ce5fa255af..921fe69cd26e 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() {