scopes = new ArrayList<>();
private RetryPolicy retryPolicy;
+ private RetryOptions retryOptions;
private Duration defaultPollInterval;
private Configurable() {
@@ -179,6 +197,19 @@ public Configurable withRetryPolicy(RetryPolicy retryPolicy) {
return this;
}
+ /**
+ * Sets the retry options for the HTTP pipeline retry policy.
+ *
+ * This setting has no effect, if retry policy is set via {@link #withRetryPolicy(RetryPolicy)}.
+ *
+ * @param retryOptions the retry options for the HTTP pipeline retry policy.
+ * @return the configurable object itself.
+ */
+ public Configurable withRetryOptions(RetryOptions retryOptions) {
+ this.retryOptions = Objects.requireNonNull(retryOptions, "'retryOptions' cannot be null.");
+ return this;
+ }
+
/**
* Sets the default poll interval, used when service does not provide "Retry-After" header.
*
@@ -186,9 +217,11 @@ public Configurable withRetryPolicy(RetryPolicy retryPolicy) {
* @return the configurable object itself.
*/
public Configurable withDefaultPollInterval(Duration defaultPollInterval) {
- this.defaultPollInterval = Objects.requireNonNull(defaultPollInterval, "'retryPolicy' cannot be null.");
+ this.defaultPollInterval =
+ Objects.requireNonNull(defaultPollInterval, "'defaultPollInterval' cannot be null.");
if (this.defaultPollInterval.isNegative()) {
- throw logger.logExceptionAsError(new IllegalArgumentException("'httpPipeline' cannot be negative"));
+ throw LOGGER
+ .logExceptionAsError(new IllegalArgumentException("'defaultPollInterval' cannot be negative"));
}
return this;
}
@@ -210,7 +243,7 @@ public HDInsightManager authenticate(TokenCredential credential, AzureProfile pr
.append("-")
.append("com.azure.resourcemanager.hdinsight")
.append("/")
- .append("1.0.0-beta.5");
+ .append("1.0.0-beta.1");
if (!Configuration.getGlobalConfiguration().get("AZURE_TELEMETRY_DISABLED", false)) {
userAgentBuilder
.append(" (")
@@ -228,16 +261,34 @@ public HDInsightManager authenticate(TokenCredential credential, AzureProfile pr
scopes.add(profile.getEnvironment().getManagementEndpoint() + "/.default");
}
if (retryPolicy == null) {
- retryPolicy = new RetryPolicy("Retry-After", ChronoUnit.SECONDS);
+ if (retryOptions != null) {
+ retryPolicy = new RetryPolicy(retryOptions);
+ } else {
+ retryPolicy = new RetryPolicy("Retry-After", ChronoUnit.SECONDS);
+ }
}
List policies = new ArrayList<>();
policies.add(new UserAgentPolicy(userAgentBuilder.toString()));
+ policies.add(new AddHeadersFromContextPolicy());
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 =
@@ -249,7 +300,11 @@ public HDInsightManager authenticate(TokenCredential credential, AzureProfile pr
}
}
- /** @return Resource collection API of Clusters. */
+ /**
+ * Gets the resource collection API of Clusters. It manages Cluster.
+ *
+ * @return Resource collection API of Clusters.
+ */
public Clusters clusters() {
if (this.clusters == null) {
this.clusters = new ClustersImpl(clientObject.getClusters(), this);
@@ -257,7 +312,11 @@ public Clusters clusters() {
return clusters;
}
- /** @return Resource collection API of Applications. */
+ /**
+ * Gets the resource collection API of Applications. It manages Application.
+ *
+ * @return Resource collection API of Applications.
+ */
public Applications applications() {
if (this.applications == null) {
this.applications = new ApplicationsImpl(clientObject.getApplications(), this);
@@ -265,7 +324,11 @@ public Applications applications() {
return applications;
}
- /** @return Resource collection API of Locations. */
+ /**
+ * Gets the resource collection API of Locations.
+ *
+ * @return Resource collection API of Locations.
+ */
public Locations locations() {
if (this.locations == null) {
this.locations = new LocationsImpl(clientObject.getLocations(), this);
@@ -273,7 +336,11 @@ public Locations locations() {
return locations;
}
- /** @return Resource collection API of Configurations. */
+ /**
+ * Gets the resource collection API of Configurations.
+ *
+ * @return Resource collection API of Configurations.
+ */
public Configurations configurations() {
if (this.configurations == null) {
this.configurations = new ConfigurationsImpl(clientObject.getConfigurations(), this);
@@ -281,7 +348,11 @@ public Configurations configurations() {
return configurations;
}
- /** @return Resource collection API of Extensions. */
+ /**
+ * Gets the resource collection API of Extensions.
+ *
+ * @return Resource collection API of Extensions.
+ */
public Extensions extensions() {
if (this.extensions == null) {
this.extensions = new ExtensionsImpl(clientObject.getExtensions(), this);
@@ -289,7 +360,11 @@ public Extensions extensions() {
return extensions;
}
- /** @return Resource collection API of ScriptActions. */
+ /**
+ * Gets the resource collection API of ScriptActions.
+ *
+ * @return Resource collection API of ScriptActions.
+ */
public ScriptActions scriptActions() {
if (this.scriptActions == null) {
this.scriptActions = new ScriptActionsImpl(clientObject.getScriptActions(), this);
@@ -297,7 +372,11 @@ public ScriptActions scriptActions() {
return scriptActions;
}
- /** @return Resource collection API of ScriptExecutionHistories. */
+ /**
+ * Gets the resource collection API of ScriptExecutionHistories.
+ *
+ * @return Resource collection API of ScriptExecutionHistories.
+ */
public ScriptExecutionHistories scriptExecutionHistories() {
if (this.scriptExecutionHistories == null) {
this.scriptExecutionHistories =
@@ -306,7 +385,11 @@ public ScriptExecutionHistories scriptExecutionHistories() {
return scriptExecutionHistories;
}
- /** @return Resource collection API of Operations. */
+ /**
+ * Gets the resource collection API of Operations.
+ *
+ * @return Resource collection API of Operations.
+ */
public Operations operations() {
if (this.operations == null) {
this.operations = new OperationsImpl(clientObject.getOperations(), this);
@@ -314,7 +397,11 @@ public Operations operations() {
return operations;
}
- /** @return Resource collection API of VirtualMachines. */
+ /**
+ * Gets the resource collection API of VirtualMachines.
+ *
+ * @return Resource collection API of VirtualMachines.
+ */
public VirtualMachines virtualMachines() {
if (this.virtualMachines == null) {
this.virtualMachines = new VirtualMachinesImpl(clientObject.getVirtualMachines(), this);
@@ -322,7 +409,11 @@ public VirtualMachines virtualMachines() {
return virtualMachines;
}
- /** @return Resource collection API of PrivateEndpointConnections. */
+ /**
+ * Gets the resource collection API of PrivateEndpointConnections. It manages PrivateEndpointConnection.
+ *
+ * @return Resource collection API of PrivateEndpointConnections.
+ */
public PrivateEndpointConnections privateEndpointConnections() {
if (this.privateEndpointConnections == null) {
this.privateEndpointConnections =
@@ -331,7 +422,11 @@ public PrivateEndpointConnections privateEndpointConnections() {
return privateEndpointConnections;
}
- /** @return Resource collection API of PrivateLinkResources. */
+ /**
+ * Gets the resource collection API of PrivateLinkResources.
+ *
+ * @return Resource collection API of PrivateLinkResources.
+ */
public PrivateLinkResources privateLinkResources() {
if (this.privateLinkResources == null) {
this.privateLinkResources = new PrivateLinkResourcesImpl(clientObject.getPrivateLinkResources(), this);
diff --git a/sdk/hdinsight/azure-resourcemanager-hdinsight/src/main/java/com/azure/resourcemanager/hdinsight/fluent/ApplicationsClient.java b/sdk/hdinsight/azure-resourcemanager-hdinsight/src/main/java/com/azure/resourcemanager/hdinsight/fluent/ApplicationsClient.java
index a954e363c451..ad99f6a26718 100644
--- a/sdk/hdinsight/azure-resourcemanager-hdinsight/src/main/java/com/azure/resourcemanager/hdinsight/fluent/ApplicationsClient.java
+++ b/sdk/hdinsight/azure-resourcemanager-hdinsight/src/main/java/com/azure/resourcemanager/hdinsight/fluent/ApplicationsClient.java
@@ -24,7 +24,7 @@ public interface ApplicationsClient {
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return result of the request to list cluster Applications.
+ * @return result of the request to list cluster Applications as paginated response with {@link PagedIterable}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedIterable listByCluster(String resourceGroupName, String clusterName);
@@ -38,7 +38,7 @@ public interface ApplicationsClient {
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return result of the request to list cluster Applications.
+ * @return result of the request to list cluster Applications as paginated response with {@link PagedIterable}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedIterable listByCluster(String resourceGroupName, String clusterName, Context context);
@@ -49,13 +49,15 @@ public interface ApplicationsClient {
* @param resourceGroupName The name of the resource group.
* @param clusterName The name of the cluster.
* @param applicationName The constant value for the application name.
+ * @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return properties of the specified application.
+ * @return properties of the specified application along with {@link Response}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
- ApplicationInner get(String resourceGroupName, String clusterName, String applicationName);
+ Response getWithResponse(
+ String resourceGroupName, String clusterName, String applicationName, Context context);
/**
* Gets properties of the specified application.
@@ -63,15 +65,13 @@ public interface ApplicationsClient {
* @param resourceGroupName The name of the resource group.
* @param clusterName The name of the cluster.
* @param applicationName The constant value for the application name.
- * @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return properties of the specified application.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
- Response getWithResponse(
- String resourceGroupName, String clusterName, String applicationName, Context context);
+ ApplicationInner get(String resourceGroupName, String clusterName, String applicationName);
/**
* Creates applications for the HDInsight cluster.
@@ -83,7 +83,7 @@ Response getWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the HDInsight cluster application.
+ * @return the {@link SyncPoller} for polling of the HDInsight cluster application.
*/
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller, ApplicationInner> beginCreate(
@@ -100,7 +100,7 @@ SyncPoller, ApplicationInner> beginCreate(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the HDInsight cluster application.
+ * @return the {@link SyncPoller} for polling of the HDInsight cluster application.
*/
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller, ApplicationInner> beginCreate(
@@ -156,7 +156,7 @@ ApplicationInner create(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link SyncPoller} for polling of long-running operation.
*/
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller, Void> beginDelete(
@@ -172,7 +172,7 @@ SyncPoller, Void> beginDelete(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link SyncPoller} for polling of long-running operation.
*/
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller, Void> beginDelete(
@@ -212,14 +212,15 @@ SyncPoller, Void> beginDelete(
* @param clusterName The name of the cluster.
* @param applicationName The constant value for the application name.
* @param operationId The long running operation id.
+ * @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the async operation status.
+ * @return the async operation status along with {@link Response}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
- AsyncOperationResultInner getAzureAsyncOperationStatus(
- String resourceGroupName, String clusterName, String applicationName, String operationId);
+ Response getAzureAsyncOperationStatusWithResponse(
+ String resourceGroupName, String clusterName, String applicationName, String operationId, Context context);
/**
* Gets the async operation status.
@@ -228,13 +229,12 @@ AsyncOperationResultInner getAzureAsyncOperationStatus(
* @param clusterName The name of the cluster.
* @param applicationName The constant value for the application name.
* @param operationId The long running operation id.
- * @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the async operation status.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
- Response getAzureAsyncOperationStatusWithResponse(
- String resourceGroupName, String clusterName, String applicationName, String operationId, Context context);
+ AsyncOperationResultInner getAzureAsyncOperationStatus(
+ String resourceGroupName, String clusterName, String applicationName, String operationId);
}
diff --git a/sdk/hdinsight/azure-resourcemanager-hdinsight/src/main/java/com/azure/resourcemanager/hdinsight/fluent/ClustersClient.java b/sdk/hdinsight/azure-resourcemanager-hdinsight/src/main/java/com/azure/resourcemanager/hdinsight/fluent/ClustersClient.java
index 4a9822d02824..24fa47127074 100644
--- a/sdk/hdinsight/azure-resourcemanager-hdinsight/src/main/java/com/azure/resourcemanager/hdinsight/fluent/ClustersClient.java
+++ b/sdk/hdinsight/azure-resourcemanager-hdinsight/src/main/java/com/azure/resourcemanager/hdinsight/fluent/ClustersClient.java
@@ -35,7 +35,7 @@ public interface ClustersClient {
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the HDInsight cluster.
+ * @return the {@link SyncPoller} for polling of the HDInsight cluster.
*/
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller, ClusterInner> beginCreate(
@@ -51,7 +51,7 @@ SyncPoller, ClusterInner> beginCreate(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the HDInsight cluster.
+ * @return the {@link SyncPoller} for polling of the HDInsight cluster.
*/
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller, ClusterInner> beginCreate(
@@ -93,13 +93,15 @@ ClusterInner create(
* @param resourceGroupName The name of the resource group.
* @param clusterName The name of the cluster.
* @param parameters The cluster patch request.
+ * @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the HDInsight cluster.
+ * @return the HDInsight cluster along with {@link Response}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
- ClusterInner update(String resourceGroupName, String clusterName, ClusterPatchParameters parameters);
+ Response updateWithResponse(
+ String resourceGroupName, String clusterName, ClusterPatchParameters parameters, Context context);
/**
* Patch HDInsight cluster with the specified parameters.
@@ -107,15 +109,13 @@ ClusterInner create(
* @param resourceGroupName The name of the resource group.
* @param clusterName The name of the cluster.
* @param parameters The cluster patch request.
- * @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the HDInsight cluster.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
- Response updateWithResponse(
- String resourceGroupName, String clusterName, ClusterPatchParameters parameters, Context context);
+ ClusterInner update(String resourceGroupName, String clusterName, ClusterPatchParameters parameters);
/**
* Deletes the specified HDInsight cluster.
@@ -125,7 +125,7 @@ Response updateWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link SyncPoller} for polling of long-running operation.
*/
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller, Void> beginDelete(String resourceGroupName, String clusterName);
@@ -139,7 +139,7 @@ Response updateWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link SyncPoller} for polling of long-running operation.
*/
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller, Void> beginDelete(String resourceGroupName, String clusterName, Context context);
@@ -174,28 +174,28 @@ Response updateWithResponse(
*
* @param resourceGroupName The name of the resource group.
* @param clusterName The name of the cluster.
+ * @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the specified cluster.
+ * @return the specified cluster along with {@link Response}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
- ClusterInner getByResourceGroup(String resourceGroupName, String clusterName);
+ Response getByResourceGroupWithResponse(
+ String resourceGroupName, String clusterName, Context context);
/**
* Gets the specified cluster.
*
* @param resourceGroupName The name of the resource group.
* @param clusterName The name of the cluster.
- * @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the specified cluster.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
- Response getByResourceGroupWithResponse(
- String resourceGroupName, String clusterName, Context context);
+ ClusterInner getByResourceGroup(String resourceGroupName, String clusterName);
/**
* Lists the HDInsight clusters in a resource group.
@@ -204,7 +204,7 @@ Response getByResourceGroupWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the List Cluster operation response.
+ * @return the List Cluster operation response as paginated response with {@link PagedIterable}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedIterable listByResourceGroup(String resourceGroupName);
@@ -217,7 +217,7 @@ Response getByResourceGroupWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the List Cluster operation response.
+ * @return the List Cluster operation response as paginated response with {@link PagedIterable}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedIterable listByResourceGroup(String resourceGroupName, Context context);
@@ -232,7 +232,7 @@ Response getByResourceGroupWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link SyncPoller} for polling of long-running operation.
*/
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller, Void> beginResize(
@@ -249,7 +249,7 @@ SyncPoller, Void> beginResize(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link SyncPoller} for polling of long-running operation.
*/
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller, Void> beginResize(
@@ -303,7 +303,7 @@ void resize(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link SyncPoller} for polling of long-running operation.
*/
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller, Void> beginUpdateAutoScaleConfiguration(
@@ -323,7 +323,7 @@ SyncPoller, Void> beginUpdateAutoScaleConfiguration(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link SyncPoller} for polling of long-running operation.
*/
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller, Void> beginUpdateAutoScaleConfiguration(
@@ -376,7 +376,7 @@ void updateAutoScaleConfiguration(
*
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the List Cluster operation response.
+ * @return the List Cluster operation response as paginated response with {@link PagedIterable}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedIterable list();
@@ -388,7 +388,7 @@ void updateAutoScaleConfiguration(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the List Cluster operation response.
+ * @return the List Cluster operation response as paginated response with {@link PagedIterable}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedIterable list(Context context);
@@ -402,7 +402,7 @@ void updateAutoScaleConfiguration(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link SyncPoller} for polling of long-running operation.
*/
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller, Void> beginRotateDiskEncryptionKey(
@@ -418,7 +418,7 @@ SyncPoller, Void> beginRotateDiskEncryptionKey(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link SyncPoller} for polling of long-running operation.
*/
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller, Void> beginRotateDiskEncryptionKey(
@@ -458,28 +458,28 @@ void rotateDiskEncryptionKey(
*
* @param resourceGroupName The name of the resource group.
* @param clusterName The name of the cluster.
+ * @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the gateway settings for the specified cluster.
+ * @return the gateway settings for the specified cluster along with {@link Response}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
- GatewaySettingsInner getGatewaySettings(String resourceGroupName, String clusterName);
+ Response getGatewaySettingsWithResponse(
+ String resourceGroupName, String clusterName, Context context);
/**
* Gets the gateway settings for the specified cluster.
*
* @param resourceGroupName The name of the resource group.
* @param clusterName The name of the cluster.
- * @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the gateway settings for the specified cluster.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
- Response getGatewaySettingsWithResponse(
- String resourceGroupName, String clusterName, Context context);
+ GatewaySettingsInner getGatewaySettings(String resourceGroupName, String clusterName);
/**
* Configures the gateway settings on the specified cluster.
@@ -490,7 +490,7 @@ Response getGatewaySettingsWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link SyncPoller} for polling of long-running operation.
*/
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller, Void> beginUpdateGatewaySettings(
@@ -506,7 +506,7 @@ SyncPoller, Void> beginUpdateGatewaySettings(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link SyncPoller} for polling of long-running operation.
*/
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller, Void> beginUpdateGatewaySettings(
@@ -547,14 +547,15 @@ void updateGatewaySettings(
* @param resourceGroupName The name of the resource group.
* @param clusterName The name of the cluster.
* @param operationId The long running operation id.
+ * @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the azure async operation response.
+ * @return the azure async operation response along with {@link Response}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
- AsyncOperationResultInner getAzureAsyncOperationStatus(
- String resourceGroupName, String clusterName, String operationId);
+ Response getAzureAsyncOperationStatusWithResponse(
+ String resourceGroupName, String clusterName, String operationId, Context context);
/**
* The the async operation status.
@@ -562,15 +563,14 @@ AsyncOperationResultInner getAzureAsyncOperationStatus(
* @param resourceGroupName The name of the resource group.
* @param clusterName The name of the cluster.
* @param operationId The long running operation id.
- * @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the azure async operation response.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
- Response getAzureAsyncOperationStatusWithResponse(
- String resourceGroupName, String clusterName, String operationId, Context context);
+ AsyncOperationResultInner getAzureAsyncOperationStatus(
+ String resourceGroupName, String clusterName, String operationId);
/**
* Updates the cluster identity certificate.
@@ -581,7 +581,7 @@ Response getAzureAsyncOperationStatusWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link SyncPoller} for polling of long-running operation.
*/
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller, Void> beginUpdateIdentityCertificate(
@@ -597,7 +597,7 @@ SyncPoller, Void> beginUpdateIdentityCertificate(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link SyncPoller} for polling of long-running operation.
*/
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller, Void> beginUpdateIdentityCertificate(
@@ -647,7 +647,7 @@ void updateIdentityCertificate(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link SyncPoller} for polling of long-running operation.
*/
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller, Void> beginExecuteScriptActions(
@@ -663,7 +663,7 @@ SyncPoller, Void> beginExecuteScriptActions(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link SyncPoller} for polling of long-running operation.
*/
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller, Void> beginExecuteScriptActions(
diff --git a/sdk/hdinsight/azure-resourcemanager-hdinsight/src/main/java/com/azure/resourcemanager/hdinsight/fluent/ConfigurationsClient.java b/sdk/hdinsight/azure-resourcemanager-hdinsight/src/main/java/com/azure/resourcemanager/hdinsight/fluent/ConfigurationsClient.java
index 73c60b4becac..2a5a8e4e350c 100644
--- a/sdk/hdinsight/azure-resourcemanager-hdinsight/src/main/java/com/azure/resourcemanager/hdinsight/fluent/ConfigurationsClient.java
+++ b/sdk/hdinsight/azure-resourcemanager-hdinsight/src/main/java/com/azure/resourcemanager/hdinsight/fluent/ConfigurationsClient.java
@@ -20,28 +20,28 @@ public interface ConfigurationsClient {
*
* @param resourceGroupName The name of the resource group.
* @param clusterName The name of the cluster.
+ * @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return all configuration information for an HDI cluster.
+ * @return all configuration information for an HDI cluster along with {@link Response}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
- ClusterConfigurationsInner list(String resourceGroupName, String clusterName);
+ Response listWithResponse(
+ String resourceGroupName, String clusterName, Context context);
/**
* Gets all configuration information for an HDI cluster.
*
* @param resourceGroupName The name of the resource group.
* @param clusterName The name of the cluster.
- * @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return all configuration information for an HDI cluster.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
- Response listWithResponse(
- String resourceGroupName, String clusterName, Context context);
+ ClusterConfigurationsInner list(String resourceGroupName, String clusterName);
/**
* Configures the HTTP settings on the specified cluster. This API is deprecated, please use UpdateGatewaySettings
@@ -54,7 +54,7 @@ Response listWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link SyncPoller} for polling of long-running operation.
*/
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller, Void> beginUpdate(
@@ -72,7 +72,7 @@ SyncPoller, Void> beginUpdate(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link SyncPoller} for polling of long-running operation.
*/
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller, Void> beginUpdate(
@@ -125,13 +125,16 @@ void update(
* @param resourceGroupName The name of the resource group.
* @param clusterName The name of the cluster.
* @param configurationName The name of the cluster configuration.
+ * @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the configuration object for the specified configuration for the specified cluster.
+ * @return the configuration object for the specified configuration for the specified cluster along with {@link
+ * Response}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
- Map get(String resourceGroupName, String clusterName, String configurationName);
+ Response