[AutoPR azure-resourcemanager-datafactory] SIG replication to edge zones

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

@@ -1,6 +1,8 @@
 # Release History
 
-## 1.0.0-beta.8 (Unreleased)
+## 1.0.0-beta.1 (2021-11-11)
+
+- Azure Resource Manager DataFactory client library for Java. This package contains Microsoft Azure SDK for DataFactory Management SDK. The Azure Data Factory V2 management API provides a RESTful set of web services that interact with Azure Data Factory V2 services. Package tag package-2018-06. For documentation on how to use this package, please see [Azure Management Libraries for Java](https://aka.ms/azsdk/java/mgmt).
 
 ### Features Added
 

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

@@ -32,7 +32,7 @@ Various documentation is available to help you get started
 <dependency>
     <groupId>com.azure.resourcemanager</groupId>
     <artifactId>azure-resourcemanager-datafactory</artifactId>
-    <version>1.0.0-beta.7</version>
+    <version>1.0.0-beta.8</version>
 </dependency>
 ```
 [//]: # ({x-version-update-end})

sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/DataFactoryManager.java

@@ -251,7 +251,7 @@ public DataFactoryManager authenticate(TokenCredential credential, AzureProfile
                 .append("-")
                 .append("com.azure.resourcemanager.datafactory")
                 .append("/")
-                .append("1.0.0-beta.7");
+                .append("1.0.0-beta.1");
             if (!Configuration.getGlobalConfiguration().get("AZURE_TELEMETRY_DISABLED", false)) {
                 userAgentBuilder
                     .append(" (")

sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DataFlowSink.java

@@ -14,12 +14,64 @@
 public class DataFlowSink extends Transformation {
     @JsonIgnore private final ClientLogger logger = new ClientLogger(DataFlowSink.class);
 
+    /*
+     * Dataset reference.
+     */
+    @JsonProperty(value = "dataset")
+    private DatasetReference dataset;
+
+    /*
+     * Linked service reference.
+     */
+    @JsonProperty(value = "linkedService")
+    private LinkedServiceReference linkedService;
+
     /*
      * Schema linked service reference.
      */
     @JsonProperty(value = "schemaLinkedService")
     private LinkedServiceReference schemaLinkedService;
 
+    /**
+     * Get the dataset property: Dataset reference.
+     *
+     * @return the dataset value.
+     */
+    public DatasetReference dataset() {
+        return this.dataset;
+    }
+
+    /**
+     * Set the dataset property: Dataset reference.
+     *
+     * @param dataset the dataset value to set.
+     * @return the DataFlowSink object itself.
+     */
+    public DataFlowSink withDataset(DatasetReference dataset) {
+        this.dataset = dataset;
+        return this;
+    }
+
+    /**
+     * Get the linkedService property: Linked service reference.
+     *
+     * @return the linkedService value.
+     */
+    public LinkedServiceReference linkedService() {
+        return this.linkedService;
+    }
+
+    /**
+     * Set the linkedService property: Linked service reference.
+     *
+     * @param linkedService the linkedService value to set.
+     * @return the DataFlowSink object itself.
+     */
+    public DataFlowSink withLinkedService(LinkedServiceReference linkedService) {
+        this.linkedService = linkedService;
+        return this;
+    }
+
     /**
      * Get the schemaLinkedService property: Schema linked service reference.
      *
@@ -54,20 +106,6 @@ public DataFlowSink withDescription(String description) {
         return this;
     }
 
-    /** {@inheritDoc} */
-    @Override
-    public DataFlowSink withDataset(DatasetReference dataset) {
-        super.withDataset(dataset);
-        return this;
-    }
-
-    /** {@inheritDoc} */
-    @Override
-    public DataFlowSink withLinkedService(LinkedServiceReference linkedService) {
-        super.withLinkedService(linkedService);
-        return this;
-    }
-
     /** {@inheritDoc} */
     @Override
     public DataFlowSink withFlowlet(DataFlowReference flowlet) {
@@ -83,6 +121,12 @@ public DataFlowSink withFlowlet(DataFlowReference flowlet) {
     @Override
     public void validate() {
         super.validate();
+        if (dataset() != null) {
+            dataset().validate();
+        }
+        if (linkedService() != null) {
+            linkedService().validate();
+        }
         if (schemaLinkedService() != null) {
             schemaLinkedService().validate();
         }

sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DataFlowSource.java

@@ -14,12 +14,64 @@
 public class DataFlowSource extends Transformation {
     @JsonIgnore private final ClientLogger logger = new ClientLogger(DataFlowSource.class);
 
+    /*
+     * Dataset reference.
+     */
+    @JsonProperty(value = "dataset")
+    private DatasetReference dataset;
+
+    /*
+     * Linked service reference.
+     */
+    @JsonProperty(value = "linkedService")
+    private LinkedServiceReference linkedService;
+
     /*
      * Schema linked service reference.
      */
     @JsonProperty(value = "schemaLinkedService")
     private LinkedServiceReference schemaLinkedService;
 
+    /**
+     * Get the dataset property: Dataset reference.
+     *
+     * @return the dataset value.
+     */
+    public DatasetReference dataset() {
+        return this.dataset;
+    }
+
+    /**
+     * Set the dataset property: Dataset reference.
+     *
+     * @param dataset the dataset value to set.
+     * @return the DataFlowSource object itself.
+     */
+    public DataFlowSource withDataset(DatasetReference dataset) {
+        this.dataset = dataset;
+        return this;
+    }
+
+    /**
+     * Get the linkedService property: Linked service reference.
+     *
+     * @return the linkedService value.
+     */
+    public LinkedServiceReference linkedService() {
+        return this.linkedService;
+    }
+
+    /**
+     * Set the linkedService property: Linked service reference.
+     *
+     * @param linkedService the linkedService value to set.
+     * @return the DataFlowSource object itself.
+     */
+    public DataFlowSource withLinkedService(LinkedServiceReference linkedService) {
+        this.linkedService = linkedService;
+        return this;
+    }
+
     /**
      * Get the schemaLinkedService property: Schema linked service reference.
      *
@@ -54,20 +106,6 @@ public DataFlowSource withDescription(String description) {
         return this;
     }
 
-    /** {@inheritDoc} */
-    @Override
-    public DataFlowSource withDataset(DatasetReference dataset) {
-        super.withDataset(dataset);
-        return this;
-    }
-
-    /** {@inheritDoc} */
-    @Override
-    public DataFlowSource withLinkedService(LinkedServiceReference linkedService) {
-        super.withLinkedService(linkedService);
-        return this;
-    }
-
     /** {@inheritDoc} */
     @Override
     public DataFlowSource withFlowlet(DataFlowReference flowlet) {
@@ -83,6 +121,12 @@ public DataFlowSource withFlowlet(DataFlowReference flowlet) {
     @Override
     public void validate() {
         super.validate();
+        if (dataset() != null) {
+            dataset().validate();
+        }
+        if (linkedService() != null) {
+            linkedService().validate();
+        }
         if (schemaLinkedService() != null) {
             schemaLinkedService().validate();
         }

sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DatasetBZip2Compression.java

@@ -0,0 +1,29 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+// Code generated by Microsoft (R) AutoRest Code Generator.
+
+package com.azure.resourcemanager.datafactory.models;
+
+import com.azure.core.annotation.Immutable;
+import com.azure.core.util.logging.ClientLogger;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonTypeInfo;
+import com.fasterxml.jackson.annotation.JsonTypeName;
+
+/** The BZip2 compression method used on a dataset. */
+@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type")
+@JsonTypeName("BZip2")
+@Immutable
+public final class DatasetBZip2Compression extends DatasetCompression {
+    @JsonIgnore private final ClientLogger logger = new ClientLogger(DatasetBZip2Compression.class);
+
+    /**
+     * Validates the instance.
+     *
+     * @throws IllegalArgumentException thrown if the instance is not valid.
+     */
+    @Override
+    public void validate() {
+        super.validate();
+    }
+}

sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DatasetCompression.java

@@ -9,74 +9,36 @@
 import com.fasterxml.jackson.annotation.JsonAnyGetter;
 import com.fasterxml.jackson.annotation.JsonAnySetter;
 import com.fasterxml.jackson.annotation.JsonIgnore;
-import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonSubTypes;
+import com.fasterxml.jackson.annotation.JsonTypeInfo;
+import com.fasterxml.jackson.annotation.JsonTypeName;
 import java.util.HashMap;
 import java.util.Map;
 
 /** The compression method used on a dataset. */
+@JsonTypeInfo(
+    use = JsonTypeInfo.Id.NAME,
+    include = JsonTypeInfo.As.PROPERTY,
+    property = "type",
+    defaultImpl = DatasetCompression.class)
+@JsonTypeName("DatasetCompression")
+@JsonSubTypes({
+    @JsonSubTypes.Type(name = "BZip2", value = DatasetBZip2Compression.class),
+    @JsonSubTypes.Type(name = "GZip", value = DatasetGZipCompression.class),
+    @JsonSubTypes.Type(name = "Deflate", value = DatasetDeflateCompression.class),
+    @JsonSubTypes.Type(name = "ZipDeflate", value = DatasetZipDeflateCompression.class),
+    @JsonSubTypes.Type(name = "Tar", value = DatasetTarCompression.class),
+    @JsonSubTypes.Type(name = "TarGZip", value = DatasetTarGZipCompression.class)
+})
 @Fluent
-public final class DatasetCompression {
+public class DatasetCompression {
     @JsonIgnore private final ClientLogger logger = new ClientLogger(DatasetCompression.class);
 
-    /*
-     * Type of dataset compression. Type: string (or Expression with resultType
-     * string).
-     */
-    @JsonProperty(value = "type", required = true)
-    private Object type;
-
-    /*
-     * The dataset compression level. Type: string (or Expression with
-     * resultType string).
-     */
-    @JsonProperty(value = "level")
-    private Object level;
-
     /*
      * The compression method used on a dataset.
      */
     @JsonIgnore private Map<String, Object> additionalProperties;
 
-    /**
-     * Get the type property: Type of dataset compression. Type: string (or Expression with resultType string).
-     *
-     * @return the type value.
-     */
-    public Object type() {
-        return this.type;
-    }
-
-    /**
-     * Set the type property: Type of dataset compression. Type: string (or Expression with resultType string).
-     *
-     * @param type the type value to set.
-     * @return the DatasetCompression object itself.
-     */
-    public DatasetCompression withType(Object type) {
-        this.type = type;
-        return this;
-    }
-
-    /**
-     * Get the level property: The dataset compression level. Type: string (or Expression with resultType string).
-     *
-     * @return the level value.
-     */
-    public Object level() {
-        return this.level;
-    }
-
-    /**
-     * Set the level property: The dataset compression level. Type: string (or Expression with resultType string).
-     *
-     * @param level the level value to set.
-     * @return the DatasetCompression object itself.
-     */
-    public DatasetCompression withLevel(Object level) {
-        this.level = level;
-        return this;
-    }
-
     /**
      * Get the additionalProperties property: The compression method used on a dataset.
      *
@@ -112,10 +74,5 @@ void withAdditionalProperties(String key, Object value) {
      * @throws IllegalArgumentException thrown if the instance is not valid.
      */
     public void validate() {
-        if (type() == null) {
-            throw logger
-                .logExceptionAsError(
-                    new IllegalArgumentException("Missing required property type in model DatasetCompression"));
-        }
     }
 }