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