upgrade synapse artifacts to package-artifacts-composite-v5 (#30994)

* upgrade synapse to package-artifacts-composite-v5 * update CHANGELOG * update CHANGELOG * update on CHANGELOG
Azure · Sep 19, 2022 · 8c52768 · 8c52768
1 parent 94534e3
commit 8c52768
Show file tree

Hide file tree

Showing 621 changed files with 5,759 additions and 4,812 deletions.
diff --git a/sdk/synapse/azure-analytics-synapse-artifacts/CHANGELOG.md b/sdk/synapse/azure-analytics-synapse-artifacts/CHANGELOG.md
@@ -1,15 +1,25 @@
 # Release History
 
-## 1.0.0-beta.11 (Unreleased)
+## 1.0.0-beta.11 (2022-09-19)
 
 ### Features Added
 
-### Breaking Changes
-
-### Bugs Fixed
+- Updated LinkConnection for Synapse Link.
+- Added TargetSparkConfiguration property for SparkJobDefinition and Notebook.
+- Added GoogleSheets connector.
+- Added SAP ODP connector.
+- Added support OAuth2ClientCredential auth in RestSevice.
+- Added support rejected data linked service in dataflow sink.
+- Added Dataworld, AppFigures, Asana, Twilio connectors.
+- Added Fail Activity.
 
 ### Other Changes
 
+#### Dependency Updates
+
+- Upgraded `azure-core` to `1.32.0`.
+- Upgraded `azure-core-http-netty` to `1.12.5`.
+
 ## 1.0.0-beta.10 (2022-04-13)
 
 ### Features Added

diff --git a/...artifacts/src/main/java/com/azure/analytics/synapse/artifacts/ArtifactsClientBuilder.java b/...artifacts/src/main/java/com/azure/analytics/synapse/artifacts/ArtifactsClientBuilder.java
@@ -154,8 +154,7 @@ public ArtifactsClientBuilder httpLogOptions(HttpLogOptions httpLogOptions) {
     }
 
     /*
-     * The client options such as application ID and custom headers to set on a
-     * request.
+     * The client options such as application ID and custom headers to set on a request.
      */
     @Generated private ClientOptions clientOptions;
 
@@ -189,8 +188,7 @@ public ArtifactsClientBuilder addPolicy(HttpPipelinePolicy customPolicy) {
     }
 
     /*
-     * The configuration store that is used during construction of the service
-     * client.
+     * The configuration store that is used during construction of the service client.
      */
     @Generated private Configuration configuration;
 
@@ -246,8 +244,7 @@ public ArtifactsClientBuilder serializerAdapter(SerializerAdapter serializerAdap
     }
 
     /*
-     * The retry policy that will attempt to retry failed requests, if
-     * applicable.
+     * The retry policy that will attempt to retry failed requests, if applicable.
      */
     @Generated private RetryPolicy retryPolicy;
 
@@ -270,13 +267,10 @@ public ArtifactsClientBuilder retryPolicy(RetryPolicy retryPolicy) {
      */
     @Generated
     private ArtifactsClientImpl buildInnerClient() {
-        if (pipeline == null) {
-            this.pipeline = createHttpPipeline();
-        }
-        if (serializerAdapter == null) {
-            this.serializerAdapter = JacksonAdapter.createDefaultSerializerAdapter();
-        }
-        ArtifactsClientImpl client = new ArtifactsClientImpl(pipeline, serializerAdapter, endpoint);
+        HttpPipeline localPipeline = (pipeline != null) ? pipeline : createHttpPipeline();
+        SerializerAdapter localSerializerAdapter =
+                (serializerAdapter != null) ? serializerAdapter : JacksonAdapter.createDefaultSerializerAdapter();
+        ArtifactsClientImpl client = new ArtifactsClientImpl(localPipeline, localSerializerAdapter, endpoint);
         return client;
     }
 

diff --git a/...pse-artifacts/src/main/java/com/azure/analytics/synapse/artifacts/LibraryAsyncClient.java b/...pse-artifacts/src/main/java/com/azure/analytics/synapse/artifacts/LibraryAsyncClient.java
@@ -14,6 +14,7 @@
 import com.azure.core.annotation.ServiceMethod;
 import com.azure.core.http.rest.PagedFlux;
 import com.azure.core.http.rest.Response;
+import com.azure.core.util.BinaryData;
 import java.nio.ByteBuffer;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
@@ -211,7 +212,7 @@ public Mono<LibraryResourceInfo> create(String libraryName) {
      * @param libraryName file name to upload. Minimum length of the filename should be 1 excluding the extension
      *     length.
      * @param content Library file chunk.
-     * @param contentLength The contentLength parameter.
+     * @param contentLength The Content-Length header for the request.
      * @param blobConditionAppendPosition Set this header to a byte offset at which the block is expected to be
      *     appended. The request succeeds only if the current offset matches this value. Otherwise, the request fails
      *     with the AppendPositionConditionNotMet error (HTTP status code 412 – Precondition Failed).
@@ -235,7 +236,7 @@ public Mono<Response<Void>> appendWithResponse(
      * @param libraryName file name to upload. Minimum length of the filename should be 1 excluding the extension
      *     length.
      * @param content Library file chunk.
-     * @param contentLength The contentLength parameter.
+     * @param contentLength The Content-Length header for the request.
      * @param blobConditionAppendPosition Set this header to a byte offset at which the block is expected to be
      *     appended. The request succeeds only if the current offset matches this value. Otherwise, the request fails
      *     with the AppendPositionConditionNotMet error (HTTP status code 412 – Precondition Failed).
@@ -258,7 +259,7 @@ public Mono<Void> append(
      * @param libraryName file name to upload. Minimum length of the filename should be 1 excluding the extension
      *     length.
      * @param content Library file chunk.
-     * @param contentLength The contentLength parameter.
+     * @param contentLength The Content-Length header for the request.
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws CloudErrorException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
@@ -269,4 +270,70 @@ public Mono<Void> append(
     public Mono<Void> append(String libraryName, Flux<ByteBuffer> content, long contentLength) {
         return this.serviceClient.appendAsync(libraryName, content, contentLength);
     }
+
+    /**
+     * Append the content to the library resource created using the create operation. The maximum content size is 4MiB.
+     * Content larger than 4MiB must be appended in 4MiB chunks.
+     *
+     * @param libraryName file name to upload. Minimum length of the filename should be 1 excluding the extension
+     *     length.
+     * @param content Library file chunk.
+     * @param contentLength The Content-Length header for the request.
+     * @param blobConditionAppendPosition Set this header to a byte offset at which the block is expected to be
+     *     appended. The request succeeds only if the current offset matches this value. Otherwise, the request fails
+     *     with the AppendPositionConditionNotMet error (HTTP status code 412 – Precondition Failed).
+     * @throws IllegalArgumentException thrown if parameters fail the validation.
+     * @throws CloudErrorException thrown if the request is rejected by server.
+     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+     * @return the {@link Response} on successful completion of {@link Mono}.
+     */
+    @Generated
+    @ServiceMethod(returns = ReturnType.SINGLE)
+    public Mono<Response<Void>> appendWithResponse(
+            String libraryName, BinaryData content, long contentLength, Long blobConditionAppendPosition) {
+        return this.serviceClient.appendWithResponseAsync(
+                libraryName, content, contentLength, blobConditionAppendPosition);
+    }
+
+    /**
+     * Append the content to the library resource created using the create operation. The maximum content size is 4MiB.
+     * Content larger than 4MiB must be appended in 4MiB chunks.
+     *
+     * @param libraryName file name to upload. Minimum length of the filename should be 1 excluding the extension
+     *     length.
+     * @param content Library file chunk.
+     * @param contentLength The Content-Length header for the request.
+     * @param blobConditionAppendPosition Set this header to a byte offset at which the block is expected to be
+     *     appended. The request succeeds only if the current offset matches this value. Otherwise, the request fails
+     *     with the AppendPositionConditionNotMet error (HTTP status code 412 – Precondition Failed).
+     * @throws IllegalArgumentException thrown if parameters fail the validation.
+     * @throws CloudErrorException thrown if the request is rejected by server.
+     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+     * @return A {@link Mono} that completes when a successful response is received.
+     */
+    @Generated
+    @ServiceMethod(returns = ReturnType.SINGLE)
+    public Mono<Void> append(
+            String libraryName, BinaryData content, long contentLength, Long blobConditionAppendPosition) {
+        return this.serviceClient.appendAsync(libraryName, content, contentLength, blobConditionAppendPosition);
+    }
+
+    /**
+     * Append the content to the library resource created using the create operation. The maximum content size is 4MiB.
+     * Content larger than 4MiB must be appended in 4MiB chunks.
+     *
+     * @param libraryName file name to upload. Minimum length of the filename should be 1 excluding the extension
+     *     length.
+     * @param content Library file chunk.
+     * @param contentLength The Content-Length header for the request.
+     * @throws IllegalArgumentException thrown if parameters fail the validation.
+     * @throws CloudErrorException thrown if the request is rejected by server.
+     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+     * @return A {@link Mono} that completes when a successful response is received.
+     */
+    @Generated
+    @ServiceMethod(returns = ReturnType.SINGLE)
+    public Mono<Void> append(String libraryName, BinaryData content, long contentLength) {
+        return this.serviceClient.appendAsync(libraryName, content, contentLength);
+    }
 }
diff --git a/...-synapse-artifacts/src/main/java/com/azure/analytics/synapse/artifacts/LibraryClient.java b/...-synapse-artifacts/src/main/java/com/azure/analytics/synapse/artifacts/LibraryClient.java
@@ -14,6 +14,7 @@
 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.BinaryData;
 import com.azure.core.util.Context;
 import java.nio.ByteBuffer;
 import reactor.core.publisher.Flux;
@@ -231,7 +232,7 @@ public Response<LibraryResourceInfo> createWithResponse(String libraryName, Cont
      * @param libraryName file name to upload. Minimum length of the filename should be 1 excluding the extension
      *     length.
      * @param content Library file chunk.
-     * @param contentLength The contentLength parameter.
+     * @param contentLength The Content-Length header for the request.
      * @param blobConditionAppendPosition Set this header to a byte offset at which the block is expected to be
      *     appended. The request succeeds only if the current offset matches this value. Otherwise, the request fails
      *     with the AppendPositionConditionNotMet error (HTTP status code 412 – Precondition Failed).
@@ -253,7 +254,7 @@ public void append(
      * @param libraryName file name to upload. Minimum length of the filename should be 1 excluding the extension
      *     length.
      * @param content Library file chunk.
-     * @param contentLength The contentLength parameter.
+     * @param contentLength The Content-Length header for the request.
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws CloudErrorException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
@@ -271,7 +272,7 @@ public void append(String libraryName, Flux<ByteBuffer> content, long contentLen
      * @param libraryName file name to upload. Minimum length of the filename should be 1 excluding the extension
      *     length.
      * @param content Library file chunk.
-     * @param contentLength The contentLength parameter.
+     * @param contentLength The Content-Length header for the request.
      * @param blobConditionAppendPosition Set this header to a byte offset at which the block is expected to be
      *     appended. The request succeeds only if the current offset matches this value. Otherwise, the request fails
      *     with the AppendPositionConditionNotMet error (HTTP status code 412 – Precondition Failed).
@@ -292,4 +293,72 @@ public Response<Void> appendWithResponse(
         return this.serviceClient.appendWithResponse(
                 libraryName, content, contentLength, blobConditionAppendPosition, context);
     }
+
+    /**
+     * Append the content to the library resource created using the create operation. The maximum content size is 4MiB.
+     * Content larger than 4MiB must be appended in 4MiB chunks.
+     *
+     * @param libraryName file name to upload. Minimum length of the filename should be 1 excluding the extension
+     *     length.
+     * @param content Library file chunk.
+     * @param contentLength The Content-Length header for the request.
+     * @param blobConditionAppendPosition Set this header to a byte offset at which the block is expected to be
+     *     appended. The request succeeds only if the current offset matches this value. Otherwise, the request fails
+     *     with the AppendPositionConditionNotMet error (HTTP status code 412 – Precondition Failed).
+     * @throws IllegalArgumentException thrown if parameters fail the validation.
+     * @throws CloudErrorException thrown if the request is rejected by server.
+     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+     */
+    @Generated
+    @ServiceMethod(returns = ReturnType.SINGLE)
+    public void append(String libraryName, BinaryData content, long contentLength, Long blobConditionAppendPosition) {
+        this.serviceClient.append(libraryName, content, contentLength, blobConditionAppendPosition);
+    }
+
+    /**
+     * Append the content to the library resource created using the create operation. The maximum content size is 4MiB.
+     * Content larger than 4MiB must be appended in 4MiB chunks.
+     *
+     * @param libraryName file name to upload. Minimum length of the filename should be 1 excluding the extension
+     *     length.
+     * @param content Library file chunk.
+     * @param contentLength The Content-Length header for the request.
+     * @throws IllegalArgumentException thrown if parameters fail the validation.
+     * @throws CloudErrorException thrown if the request is rejected by server.
+     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+     */
+    @Generated
+    @ServiceMethod(returns = ReturnType.SINGLE)
+    public void append(String libraryName, BinaryData content, long contentLength) {
+        this.serviceClient.append(libraryName, content, contentLength);
+    }
+
+    /**
+     * Append the content to the library resource created using the create operation. The maximum content size is 4MiB.
+     * Content larger than 4MiB must be appended in 4MiB chunks.
+     *
+     * @param libraryName file name to upload. Minimum length of the filename should be 1 excluding the extension
+     *     length.
+     * @param content Library file chunk.
+     * @param contentLength The Content-Length header for the request.
+     * @param blobConditionAppendPosition Set this header to a byte offset at which the block is expected to be
+     *     appended. The request succeeds only if the current offset matches this value. Otherwise, the request fails
+     *     with the AppendPositionConditionNotMet error (HTTP status code 412 – Precondition Failed).
+     * @param context The context to associate with this operation.
+     * @throws IllegalArgumentException thrown if parameters fail the validation.
+     * @throws CloudErrorException thrown if the request is rejected by server.
+     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+     * @return the {@link Response}.
+     */
+    @Generated
+    @ServiceMethod(returns = ReturnType.SINGLE)
+    public Response<Void> appendWithResponse(
+            String libraryName,
+            BinaryData content,
+            long contentLength,
+            Long blobConditionAppendPosition,
+            Context context) {
+        return this.serviceClient.appendWithResponse(
+                libraryName, content, contentLength, blobConditionAppendPosition, context);
+    }
 }
diff --git a/.../src/main/java/com/azure/analytics/synapse/artifacts/implementation/BigDataPoolsImpl.java b/.../src/main/java/com/azure/analytics/synapse/artifacts/implementation/BigDataPoolsImpl.java
@@ -109,15 +109,7 @@ public Mono<Response<BigDataPoolResourceInfoListResult>> listWithResponseAsync(C
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     public Mono<BigDataPoolResourceInfoListResult> listAsync() {
-        return listWithResponseAsync()
-                .flatMap(
-                        (Response<BigDataPoolResourceInfoListResult> res) -> {
-                            if (res.getValue() != null) {
-                                return Mono.just(res.getValue());
-                            } else {
-                                return Mono.empty();
-                            }
-                        });
+        return listWithResponseAsync().flatMap(res -> Mono.justOrEmpty(res.getValue()));
     }
 
     /**
@@ -131,15 +123,7 @@ public Mono<BigDataPoolResourceInfoListResult> listAsync() {
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     public Mono<BigDataPoolResourceInfoListResult> listAsync(Context context) {
-        return listWithResponseAsync(context)
-                .flatMap(
-                        (Response<BigDataPoolResourceInfoListResult> res) -> {
-                            if (res.getValue() != null) {
-                                return Mono.just(res.getValue());
-                            } else {
-                                return Mono.empty();
-                            }
-                        });
+        return listWithResponseAsync(context).flatMap(res -> Mono.justOrEmpty(res.getValue()));
     }
 
     /**
@@ -213,15 +197,7 @@ public Mono<Response<BigDataPoolResourceInfo>> getWithResponseAsync(String bigDa
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     public Mono<BigDataPoolResourceInfo> getAsync(String bigDataPoolName) {
-        return getWithResponseAsync(bigDataPoolName)
-                .flatMap(
-                        (Response<BigDataPoolResourceInfo> res) -> {
-                            if (res.getValue() != null) {
-                                return Mono.just(res.getValue());
-                            } else {
-                                return Mono.empty();
-                            }
-                        });
+        return getWithResponseAsync(bigDataPoolName).flatMap(res -> Mono.justOrEmpty(res.getValue()));
     }
 
     /**
@@ -236,15 +212,7 @@ public Mono<BigDataPoolResourceInfo> getAsync(String bigDataPoolName) {
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     public Mono<BigDataPoolResourceInfo> getAsync(String bigDataPoolName, Context context) {
-        return getWithResponseAsync(bigDataPoolName, context)
-                .flatMap(
-                        (Response<BigDataPoolResourceInfo> res) -> {
-                            if (res.getValue() != null) {
-                                return Mono.just(res.getValue());
-                            } else {
-                                return Mono.empty();
-                            }
-                        });
+        return getWithResponseAsync(bigDataPoolName, context).flatMap(res -> Mono.justOrEmpty(res.getValue()));
     }
 
     /**