Generated from f6874e25b943ae5075167c192ed428ec33581f65 (#4734)

Add table option to copy sink

datafactory/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AvroCompressionCodec.java

@@ -0,0 +1,50 @@
+/**
+ * Copyright (c) Microsoft Corporation. All rights reserved.
+ * Licensed under the MIT License. See License.txt in the project root for
+ * license information.
+ *
+ * Code generated by Microsoft (R) AutoRest Code Generator.
+ */
+
+package com.microsoft.azure.management.datafactory.v2018_06_01;
+
+import java.util.Collection;
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.microsoft.rest.ExpandableStringEnum;
+
+/**
+ * Defines values for AvroCompressionCodec.
+ */
+public final class AvroCompressionCodec extends ExpandableStringEnum<AvroCompressionCodec> {
+    /** Static value none for AvroCompressionCodec. */
+    public static final AvroCompressionCodec NONE = fromString("none");
+
+    /** Static value deflate for AvroCompressionCodec. */
+    public static final AvroCompressionCodec DEFLATE = fromString("deflate");
+
+    /** Static value snappy for AvroCompressionCodec. */
+    public static final AvroCompressionCodec SNAPPY = fromString("snappy");
+
+    /** Static value xz for AvroCompressionCodec. */
+    public static final AvroCompressionCodec XZ = fromString("xz");
+
+    /** Static value bzip2 for AvroCompressionCodec. */
+    public static final AvroCompressionCodec BZIP2 = fromString("bzip2");
+
+    /**
+     * Creates or finds a AvroCompressionCodec from its string representation.
+     * @param name a name to look for
+     * @return the corresponding AvroCompressionCodec
+     */
+    @JsonCreator
+    public static AvroCompressionCodec fromString(String name) {
+        return fromString(name, AvroCompressionCodec.class);
+    }
+
+    /**
+     * @return known AvroCompressionCodec values
+     */
+    public static Collection<AvroCompressionCodec> values() {
+        return values(AvroCompressionCodec.class);
+    }
+}

datafactory/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AvroDataset.java

@@ -0,0 +1,102 @@
+/**
+ * Copyright (c) Microsoft Corporation. All rights reserved.
+ * Licensed under the MIT License. See License.txt in the project root for
+ * license information.
+ *
+ * Code generated by Microsoft (R) AutoRest Code Generator.
+ */
+
+package com.microsoft.azure.management.datafactory.v2018_06_01;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonTypeInfo;
+import com.fasterxml.jackson.annotation.JsonTypeName;
+import com.microsoft.rest.serializer.JsonFlatten;
+import com.microsoft.azure.management.datafactory.v2018_06_01.implementation.DatasetInner;
+
+/**
+ * Avro dataset.
+ */
+@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type")
+@JsonTypeName("Avro")
+@JsonFlatten
+public class AvroDataset extends DatasetInner {
+    /**
+     * The location of the avro storage.
+     */
+    @JsonProperty(value = "typeProperties.location", required = true)
+    private DatasetLocation location;
+
+    /**
+     * Possible values include: 'none', 'deflate', 'snappy', 'xz', 'bzip2'.
+     */
+    @JsonProperty(value = "typeProperties.avroCompressionCodec")
+    private AvroCompressionCodec avroCompressionCodec;
+
+    /**
+     * The avroCompressionLevel property.
+     */
+    @JsonProperty(value = "typeProperties.avroCompressionLevel")
+    private Integer avroCompressionLevel;
+
+    /**
+     * Get the location of the avro storage.
+     *
+     * @return the location value
+     */
+    public DatasetLocation location() {
+        return this.location;
+    }
+
+    /**
+     * Set the location of the avro storage.
+     *
+     * @param location the location value to set
+     * @return the AvroDataset object itself.
+     */
+    public AvroDataset withLocation(DatasetLocation location) {
+        this.location = location;
+        return this;
+    }
+
+    /**
+     * Get possible values include: 'none', 'deflate', 'snappy', 'xz', 'bzip2'.
+     *
+     * @return the avroCompressionCodec value
+     */
+    public AvroCompressionCodec avroCompressionCodec() {
+        return this.avroCompressionCodec;
+    }
+
+    /**
+     * Set possible values include: 'none', 'deflate', 'snappy', 'xz', 'bzip2'.
+     *
+     * @param avroCompressionCodec the avroCompressionCodec value to set
+     * @return the AvroDataset object itself.
+     */
+    public AvroDataset withAvroCompressionCodec(AvroCompressionCodec avroCompressionCodec) {
+        this.avroCompressionCodec = avroCompressionCodec;
+        return this;
+    }
+
+    /**
+     * Get the avroCompressionLevel value.
+     *
+     * @return the avroCompressionLevel value
+     */
+    public Integer avroCompressionLevel() {
+        return this.avroCompressionLevel;
+    }
+
+    /**
+     * Set the avroCompressionLevel value.
+     *
+     * @param avroCompressionLevel the avroCompressionLevel value to set
+     * @return the AvroDataset object itself.
+     */
+    public AvroDataset withAvroCompressionLevel(Integer avroCompressionLevel) {
+        this.avroCompressionLevel = avroCompressionLevel;
+        return this;
+    }
+
+}

datafactory/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AvroSink.java

@@ -0,0 +1,73 @@
+/**
+ * Copyright (c) Microsoft Corporation. All rights reserved.
+ * Licensed under the MIT License. See License.txt in the project root for
+ * license information.
+ *
+ * Code generated by Microsoft (R) AutoRest Code Generator.
+ */
+
+package com.microsoft.azure.management.datafactory.v2018_06_01;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonTypeInfo;
+import com.fasterxml.jackson.annotation.JsonTypeName;
+
+/**
+ * A copy activity Avro sink.
+ */
+@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type")
+@JsonTypeName("AvroSink")
+public class AvroSink extends CopySink {
+    /**
+     * Avro store settings.
+     */
+    @JsonProperty(value = "storeSettings")
+    private StoreWriteSettings storeSettings;
+
+    /**
+     * Avro format settings.
+     */
+    @JsonProperty(value = "formatSettings")
+    private AvroWriteSettings formatSettings;
+
+    /**
+     * Get avro store settings.
+     *
+     * @return the storeSettings value
+     */
+    public StoreWriteSettings storeSettings() {
+        return this.storeSettings;
+    }
+
+    /**
+     * Set avro store settings.
+     *
+     * @param storeSettings the storeSettings value to set
+     * @return the AvroSink object itself.
+     */
+    public AvroSink withStoreSettings(StoreWriteSettings storeSettings) {
+        this.storeSettings = storeSettings;
+        return this;
+    }
+
+    /**
+     * Get avro format settings.
+     *
+     * @return the formatSettings value
+     */
+    public AvroWriteSettings formatSettings() {
+        return this.formatSettings;
+    }
+
+    /**
+     * Set avro format settings.
+     *
+     * @param formatSettings the formatSettings value to set
+     * @return the AvroSink object itself.
+     */
+    public AvroSink withFormatSettings(AvroWriteSettings formatSettings) {
+        this.formatSettings = formatSettings;
+        return this;
+    }
+
+}

datafactory/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AvroSource.java

@@ -0,0 +1,47 @@
+/**
+ * Copyright (c) Microsoft Corporation. All rights reserved.
+ * Licensed under the MIT License. See License.txt in the project root for
+ * license information.
+ *
+ * Code generated by Microsoft (R) AutoRest Code Generator.
+ */
+
+package com.microsoft.azure.management.datafactory.v2018_06_01;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonTypeInfo;
+import com.fasterxml.jackson.annotation.JsonTypeName;
+
+/**
+ * A copy activity Avro source.
+ */
+@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type")
+@JsonTypeName("AvroSource")
+public class AvroSource extends CopySource {
+    /**
+     * Avro store settings.
+     */
+    @JsonProperty(value = "storeSettings")
+    private StoreReadSettings storeSettings;
+
+    /**
+     * Get avro store settings.
+     *
+     * @return the storeSettings value
+     */
+    public StoreReadSettings storeSettings() {
+        return this.storeSettings;
+    }
+
+    /**
+     * Set avro store settings.
+     *
+     * @param storeSettings the storeSettings value to set
+     * @return the AvroSource object itself.
+     */
+    public AvroSource withStoreSettings(StoreReadSettings storeSettings) {
+        this.storeSettings = storeSettings;
+        return this;
+    }
+
+}

datafactory/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AvroWriteSettings.java

@@ -0,0 +1,69 @@
+/**
+ * Copyright (c) Microsoft Corporation. All rights reserved.
+ * Licensed under the MIT License. See License.txt in the project root for
+ * license information.
+ *
+ * Code generated by Microsoft (R) AutoRest Code Generator.
+ */
+
+package com.microsoft.azure.management.datafactory.v2018_06_01;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/**
+ * Avro write settings.
+ */
+public class AvroWriteSettings extends FormatWriteSettings {
+    /**
+     * Top level record name in write result, which is required in AVRO spec.
+     */
+    @JsonProperty(value = "recordName")
+    private String recordName;
+
+    /**
+     * Record namespace in the write result.
+     */
+    @JsonProperty(value = "recordNamespace")
+    private String recordNamespace;
+
+    /**
+     * Get top level record name in write result, which is required in AVRO spec.
+     *
+     * @return the recordName value
+     */
+    public String recordName() {
+        return this.recordName;
+    }
+
+    /**
+     * Set top level record name in write result, which is required in AVRO spec.
+     *
+     * @param recordName the recordName value to set
+     * @return the AvroWriteSettings object itself.
+     */
+    public AvroWriteSettings withRecordName(String recordName) {
+        this.recordName = recordName;
+        return this;
+    }
+
+    /**
+     * Get record namespace in the write result.
+     *
+     * @return the recordNamespace value
+     */
+    public String recordNamespace() {
+        return this.recordNamespace;
+    }
+
+    /**
+     * Set record namespace in the write result.
+     *
+     * @param recordNamespace the recordNamespace value to set
+     * @return the AvroWriteSettings object itself.
+     */
+    public AvroWriteSettings withRecordNamespace(String recordNamespace) {
+        this.recordNamespace = recordNamespace;
+        return this;
+    }
+
+}

datafactory/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CopySink.java

@@ -44,6 +44,7 @@
     @JsonSubTypes.Type(name = "BlobSink", value = BlobSink.class),
     @JsonSubTypes.Type(name = "BinarySink", value = BinarySink.class),
     @JsonSubTypes.Type(name = "ParquetSink", value = ParquetSink.class),
+    @JsonSubTypes.Type(name = "AvroSink", value = AvroSink.class),
     @JsonSubTypes.Type(name = "AzureTableSink", value = AzureTableSink.class),
     @JsonSubTypes.Type(name = "AzureQueueSink", value = AzureQueueSink.class),
     @JsonSubTypes.Type(name = "SapCloudForCustomerSink", value = SapCloudForCustomerSink.class),
@@ -91,6 +92,14 @@ public class CopySink {
     @JsonProperty(value = "maxConcurrentConnections")
     private Object maxConcurrentConnections;
 
+    /**
+     * The option to handle sink table, such as autoCreate. For now only
+     * 'autoCreate' value is supported. Type: string (or Expression with
+     * resultType string).
+     */
+    @JsonProperty(value = "tableOption")
+    private Object tableOption;
+
     /**
      * Get unmatched properties from the message are deserialized this collection.
      *
@@ -211,4 +220,24 @@ public CopySink withMaxConcurrentConnections(Object maxConcurrentConnections) {
         return this;
     }
 
+    /**
+     * Get the option to handle sink table, such as autoCreate. For now only 'autoCreate' value is supported. Type: string (or Expression with resultType string).
+     *
+     * @return the tableOption value
+     */
+    public Object tableOption() {
+        return this.tableOption;
+    }
+
+    /**
+     * Set the option to handle sink table, such as autoCreate. For now only 'autoCreate' value is supported. Type: string (or Expression with resultType string).
+     *
+     * @param tableOption the tableOption value to set
+     * @return the CopySink object itself.
+     */
+    public CopySink withTableOption(Object tableOption) {
+        this.tableOption = tableOption;
+        return this;
+    }
+
 }