[AutoPR azure-resourcemanager-synapse] Kusto pools principal assignment

sdk/synapse/azure-resourcemanager-synapse/CHANGELOG.md

@@ -1,7 +1,8 @@
 # Release History
 
-## 1.0.0-beta.2 (Unreleased)
+## 1.0.0-beta.1 (2021-04-27)
 
+- Azure Resource Manager Synapse client library for Java. This package contains Microsoft Azure SDK for Synapse Management SDK. Azure Synapse Analytics Management Client. Package tag package-2021-04-preview. For documentation on how to use this package, please see [Azure Management Libraries for Java](https://aka.ms/azsdk/java/mgmt).
 
 ## 1.0.0-beta.1 (2021-04-07)
 

sdk/synapse/azure-resourcemanager-synapse/README.md

@@ -2,7 +2,7 @@
 
 Azure Resource Manager Synapse client library for Java.
 
-This package contains Microsoft Azure SDK for Synapse Management SDK. Azure Synapse Analytics Management Client. Package tag package-2021-03. For documentation on how to use this package, please see [Azure Management Libraries for Java](https://aka.ms/azsdk/java/mgmt).
+This package contains Microsoft Azure SDK for Synapse Management SDK. Azure Synapse Analytics Management Client. Package tag package-2021-04-preview. For documentation on how to use this package, please see [Azure Management Libraries for Java](https://aka.ms/azsdk/java/mgmt).
 
 ## We'd love to hear your feedback
 
@@ -32,7 +32,7 @@ Various documentation is available to help you get started
 <dependency>
     <groupId>com.azure.resourcemanager</groupId>
     <artifactId>azure-resourcemanager-synapse</artifactId>
-    <version>1.0.0-beta.1</version>
+    <version>1.0.0-beta.2</version>
 </dependency>
 ```
 [//]: # ({x-version-update-end})

sdk/synapse/azure-resourcemanager-synapse/pom.xml

@@ -13,7 +13,7 @@
     <packaging>jar</packaging>
 
     <name>Microsoft Azure SDK for Synapse Management</name>
-    <description>This package contains Microsoft Azure SDK for Synapse Management SDK. For documentation on how to use this package, please see https://aka.ms/azsdk/java/mgmt. Azure Synapse Analytics Management Client. Package tag package-2021-03.</description>
+    <description>This package contains Microsoft Azure SDK for Synapse Management SDK. For documentation on how to use this package, please see https://aka.ms/azsdk/java/mgmt. Azure Synapse Analytics Management Client. Package tag package-2021-04-preview.</description>
     <url>https://github.com/Azure/azure-sdk-for-java</url>
 
     <licenses>

sdk/synapse/azure-resourcemanager-synapse/src/main/java/com/azure/resourcemanager/synapse/fluent/PrivateEndpointConnectionsPrivateLinkHubsClient.java

@@ -7,6 +7,7 @@
 import com.azure.core.annotation.ReturnType;
 import com.azure.core.annotation.ServiceMethod;
 import com.azure.core.http.rest.PagedIterable;
+import com.azure.core.http.rest.Response;
 import com.azure.core.util.Context;
 import com.azure.resourcemanager.synapse.fluent.models.PrivateEndpointConnectionForPrivateLinkHubInner;
 
@@ -43,4 +44,35 @@ PagedIterable<PrivateEndpointConnectionForPrivateLinkHubInner> list(
     @ServiceMethod(returns = ReturnType.COLLECTION)
     PagedIterable<PrivateEndpointConnectionForPrivateLinkHubInner> list(
         String resourceGroupName, String privateLinkHubName, Context context);
+
+    /**
+     * Get all PrivateEndpointConnection in the PrivateLinkHub by name.
+     *
+     * @param resourceGroupName The name of the resource group. The name is case insensitive.
+     * @param privateLinkHubName Name of the privateLinkHub.
+     * @param privateEndpointConnectionName Name of the privateEndpointConnection.
+     * @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 PrivateEndpointConnection in the PrivateLinkHub by name.
+     */
+    @ServiceMethod(returns = ReturnType.SINGLE)
+    PrivateEndpointConnectionForPrivateLinkHubInner get(
+        String resourceGroupName, String privateLinkHubName, String privateEndpointConnectionName);
+
+    /**
+     * Get all PrivateEndpointConnection in the PrivateLinkHub by name.
+     *
+     * @param resourceGroupName The name of the resource group. The name is case insensitive.
+     * @param privateLinkHubName Name of the privateLinkHub.
+     * @param privateEndpointConnectionName Name of the privateEndpointConnection.
+     * @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 PrivateEndpointConnection in the PrivateLinkHub by name.
+     */
+    @ServiceMethod(returns = ReturnType.SINGLE)
+    Response<PrivateEndpointConnectionForPrivateLinkHubInner> getWithResponse(
+        String resourceGroupName, String privateLinkHubName, String privateEndpointConnectionName, Context context);
 }

sdk/synapse/azure-resourcemanager-synapse/src/main/java/com/azure/resourcemanager/synapse/fluent/models/WorkspaceInner.java

@@ -136,7 +136,7 @@ public class WorkspaceInner extends Resource {
     private String adlaResourceId;
 
     /*
-     * Enable or Disable pubic network access to workspace
+     * Enable or Disable public network access to workspace
      */
     @JsonProperty(value = "properties.publicNetworkAccess")
     private WorkspacePublicNetworkAccess publicNetworkAccess;
@@ -449,7 +449,7 @@ public String adlaResourceId() {
     }
 
     /**
-     * Get the publicNetworkAccess property: Enable or Disable pubic network access to workspace.
+     * Get the publicNetworkAccess property: Enable or Disable public network access to workspace.
      *
      * @return the publicNetworkAccess value.
      */
@@ -458,7 +458,7 @@ public WorkspacePublicNetworkAccess publicNetworkAccess() {
     }
 
     /**
-     * Set the publicNetworkAccess property: Enable or Disable pubic network access to workspace.
+     * Set the publicNetworkAccess property: Enable or Disable public network access to workspace.
      *
      * @param publicNetworkAccess the publicNetworkAccess value to set.
      * @return the WorkspaceInner object itself.

sdk/synapse/azure-resourcemanager-synapse/src/main/java/com/azure/resourcemanager/synapse/implementation/PrivateEndpointConnectionsPrivateLinkHubsClientImpl.java

@@ -82,6 +82,22 @@ Mono<Response<PrivateEndpointConnectionForPrivateLinkHubResourceCollectionRespon
             @HeaderParam("Accept") String accept,
             Context context);
 
+        @Headers({"Content-Type: application/json"})
+        @Get(
+            "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Synapse"
+                + "/privateLinkHubs/{privateLinkHubName}/privateEndpointConnections/{privateEndpointConnectionName}")
+        @ExpectedResponses({200})
+        @UnexpectedResponseExceptionType(ManagementException.class)
+        Mono<Response<PrivateEndpointConnectionForPrivateLinkHubInner>> get(
+            @HostParam("$host") String endpoint,
+            @QueryParam("api-version") String apiVersion,
+            @PathParam("subscriptionId") String subscriptionId,
+            @PathParam("resourceGroupName") String resourceGroupName,
+            @PathParam("privateLinkHubName") String privateLinkHubName,
+            @PathParam("privateEndpointConnectionName") String privateEndpointConnectionName,
+            @HeaderParam("Accept") String accept,
+            Context context);
+
         @Headers({"Content-Type: application/json"})
         @Get("{nextLink}")
         @ExpectedResponses({200})
@@ -277,6 +293,179 @@ public PagedIterable<PrivateEndpointConnectionForPrivateLinkHubInner> list(
         return new PagedIterable<>(listAsync(resourceGroupName, privateLinkHubName, context));
     }
 
+    /**
+     * Get all PrivateEndpointConnection in the PrivateLinkHub by name.
+     *
+     * @param resourceGroupName The name of the resource group. The name is case insensitive.
+     * @param privateLinkHubName Name of the privateLinkHub.
+     * @param privateEndpointConnectionName Name of the privateEndpointConnection.
+     * @throws IllegalArgumentException thrown if parameters fail the validation.
+     * @throws 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 PrivateEndpointConnection in the PrivateLinkHub by name.
+     */
+    @ServiceMethod(returns = ReturnType.SINGLE)
+    private Mono<Response<PrivateEndpointConnectionForPrivateLinkHubInner>> getWithResponseAsync(
+        String resourceGroupName, String privateLinkHubName, String privateEndpointConnectionName) {
+        if (this.client.getEndpoint() == null) {
+            return Mono
+                .error(
+                    new IllegalArgumentException(
+                        "Parameter this.client.getEndpoint() is required and cannot be null."));
+        }
+        if (this.client.getSubscriptionId() == null) {
+            return Mono
+                .error(
+                    new IllegalArgumentException(
+                        "Parameter this.client.getSubscriptionId() is required and cannot be null."));
+        }
+        if (resourceGroupName == null) {
+            return Mono
+                .error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
+        }
+        if (privateLinkHubName == null) {
+            return Mono
+                .error(new IllegalArgumentException("Parameter privateLinkHubName is required and cannot be null."));
+        }
+        if (privateEndpointConnectionName == null) {
+            return Mono
+                .error(
+                    new IllegalArgumentException(
+                        "Parameter privateEndpointConnectionName is required and cannot be null."));
+        }
+        final String accept = "application/json";
+        return FluxUtil
+            .withContext(
+                context ->
+                    service
+                        .get(
+                            this.client.getEndpoint(),
+                            this.client.getApiVersion(),
+                            this.client.getSubscriptionId(),
+                            resourceGroupName,
+                            privateLinkHubName,
+                            privateEndpointConnectionName,
+                            accept,
+                            context))
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
+    }
+
+    /**
+     * Get all PrivateEndpointConnection in the PrivateLinkHub by name.
+     *
+     * @param resourceGroupName The name of the resource group. The name is case insensitive.
+     * @param privateLinkHubName Name of the privateLinkHub.
+     * @param privateEndpointConnectionName Name of the privateEndpointConnection.
+     * @param context The context to associate with this operation.
+     * @throws IllegalArgumentException thrown if parameters fail the validation.
+     * @throws 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 PrivateEndpointConnection in the PrivateLinkHub by name.
+     */
+    @ServiceMethod(returns = ReturnType.SINGLE)
+    private Mono<Response<PrivateEndpointConnectionForPrivateLinkHubInner>> getWithResponseAsync(
+        String resourceGroupName, String privateLinkHubName, String privateEndpointConnectionName, Context context) {
+        if (this.client.getEndpoint() == null) {
+            return Mono
+                .error(
+                    new IllegalArgumentException(
+                        "Parameter this.client.getEndpoint() is required and cannot be null."));
+        }
+        if (this.client.getSubscriptionId() == null) {
+            return Mono
+                .error(
+                    new IllegalArgumentException(
+                        "Parameter this.client.getSubscriptionId() is required and cannot be null."));
+        }
+        if (resourceGroupName == null) {
+            return Mono
+                .error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
+        }
+        if (privateLinkHubName == null) {
+            return Mono
+                .error(new IllegalArgumentException("Parameter privateLinkHubName is required and cannot be null."));
+        }
+        if (privateEndpointConnectionName == null) {
+            return Mono
+                .error(
+                    new IllegalArgumentException(
+                        "Parameter privateEndpointConnectionName is required and cannot be null."));
+        }
+        final String accept = "application/json";
+        context = this.client.mergeContext(context);
+        return service
+            .get(
+                this.client.getEndpoint(),
+                this.client.getApiVersion(),
+                this.client.getSubscriptionId(),
+                resourceGroupName,
+                privateLinkHubName,
+                privateEndpointConnectionName,
+                accept,
+                context);
+    }
+
+    /**
+     * Get all PrivateEndpointConnection in the PrivateLinkHub by name.
+     *
+     * @param resourceGroupName The name of the resource group. The name is case insensitive.
+     * @param privateLinkHubName Name of the privateLinkHub.
+     * @param privateEndpointConnectionName Name of the privateEndpointConnection.
+     * @throws IllegalArgumentException thrown if parameters fail the validation.
+     * @throws 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 PrivateEndpointConnection in the PrivateLinkHub by name.
+     */
+    @ServiceMethod(returns = ReturnType.SINGLE)
+    private Mono<PrivateEndpointConnectionForPrivateLinkHubInner> getAsync(
+        String resourceGroupName, String privateLinkHubName, String privateEndpointConnectionName) {
+        return getWithResponseAsync(resourceGroupName, privateLinkHubName, privateEndpointConnectionName)
+            .flatMap(
+                (Response<PrivateEndpointConnectionForPrivateLinkHubInner> res) -> {
+                    if (res.getValue() != null) {
+                        return Mono.just(res.getValue());
+                    } else {
+                        return Mono.empty();
+                    }
+                });
+    }
+
+    /**
+     * Get all PrivateEndpointConnection in the PrivateLinkHub by name.
+     *
+     * @param resourceGroupName The name of the resource group. The name is case insensitive.
+     * @param privateLinkHubName Name of the privateLinkHub.
+     * @param privateEndpointConnectionName Name of the privateEndpointConnection.
+     * @throws IllegalArgumentException thrown if parameters fail the validation.
+     * @throws 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 PrivateEndpointConnection in the PrivateLinkHub by name.
+     */
+    @ServiceMethod(returns = ReturnType.SINGLE)
+    public PrivateEndpointConnectionForPrivateLinkHubInner get(
+        String resourceGroupName, String privateLinkHubName, String privateEndpointConnectionName) {
+        return getAsync(resourceGroupName, privateLinkHubName, privateEndpointConnectionName).block();
+    }
+
+    /**
+     * Get all PrivateEndpointConnection in the PrivateLinkHub by name.
+     *
+     * @param resourceGroupName The name of the resource group. The name is case insensitive.
+     * @param privateLinkHubName Name of the privateLinkHub.
+     * @param privateEndpointConnectionName Name of the privateEndpointConnection.
+     * @param context The context to associate with this operation.
+     * @throws IllegalArgumentException thrown if parameters fail the validation.
+     * @throws 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 PrivateEndpointConnection in the PrivateLinkHub by name.
+     */
+    @ServiceMethod(returns = ReturnType.SINGLE)
+    public Response<PrivateEndpointConnectionForPrivateLinkHubInner> getWithResponse(
+        String resourceGroupName, String privateLinkHubName, String privateEndpointConnectionName, Context context) {
+        return getWithResponseAsync(resourceGroupName, privateLinkHubName, privateEndpointConnectionName, context)
+            .block();
+    }
+
     /**
      * Get the next page of items.
      *

sdk/synapse/azure-resourcemanager-synapse/src/main/java/com/azure/resourcemanager/synapse/implementation/PrivateEndpointConnectionsPrivateLinkHubsImpl.java

@@ -5,6 +5,8 @@
 package com.azure.resourcemanager.synapse.implementation;
 
 import com.azure.core.http.rest.PagedIterable;
+import com.azure.core.http.rest.Response;
+import com.azure.core.http.rest.SimpleResponse;
 import com.azure.core.util.Context;
 import com.azure.core.util.logging.ClientLogger;
 import com.azure.resourcemanager.synapse.fluent.PrivateEndpointConnectionsPrivateLinkHubsClient;
@@ -44,6 +46,34 @@ public PagedIterable<PrivateEndpointConnectionForPrivateLinkHub> list(
             .mapPage(inner, inner1 -> new PrivateEndpointConnectionForPrivateLinkHubImpl(inner1, this.manager()));
     }
 
+    public PrivateEndpointConnectionForPrivateLinkHub get(
+        String resourceGroupName, String privateLinkHubName, String privateEndpointConnectionName) {
+        PrivateEndpointConnectionForPrivateLinkHubInner inner =
+            this.serviceClient().get(resourceGroupName, privateLinkHubName, privateEndpointConnectionName);
+        if (inner != null) {
+            return new PrivateEndpointConnectionForPrivateLinkHubImpl(inner, this.manager());
+        } else {
+            return null;
+        }
+    }
+
+    public Response<PrivateEndpointConnectionForPrivateLinkHub> getWithResponse(
+        String resourceGroupName, String privateLinkHubName, String privateEndpointConnectionName, Context context) {
+        Response<PrivateEndpointConnectionForPrivateLinkHubInner> inner =
+            this
+                .serviceClient()
+                .getWithResponse(resourceGroupName, privateLinkHubName, privateEndpointConnectionName, context);
+        if (inner != null) {
+            return new SimpleResponse<>(
+                inner.getRequest(),
+                inner.getStatusCode(),
+                inner.getHeaders(),
+                new PrivateEndpointConnectionForPrivateLinkHubImpl(inner.getValue(), this.manager()));
+        } else {
+            return null;
+        }
+    }
+
     private PrivateEndpointConnectionsPrivateLinkHubsClient serviceClient() {
         return this.innerClient;
     }

sdk/synapse/azure-resourcemanager-synapse/src/main/java/com/azure/resourcemanager/synapse/implementation/SynapseManagementClientImpl.java

@@ -928,7 +928,7 @@ public RestorableDroppedSqlPoolsClient getRestorableDroppedSqlPools() {
         this.defaultPollInterval = defaultPollInterval;
         this.subscriptionId = subscriptionId;
         this.endpoint = endpoint;
-        this.apiVersion = "2021-03-01";
+        this.apiVersion = "2021-04-01-preview";
         this.bigDataPools = new BigDataPoolsClientImpl(this);
         this.operations = new OperationsClientImpl(this);
         this.ipFirewallRules = new IpFirewallRulesClientImpl(this);