From 01eb738281a2766c8d802f8f9b068b2bbe539b2a Mon Sep 17 00:00:00 2001 From: "openapi-bot[bot]" <37845953+openapi-bot[bot]@users.noreply.github.com> Date: Wed, 14 Aug 2019 09:37:28 +0000 Subject: [PATCH] Generated from f6874e25b943ae5075167c192ed428ec33581f65 (#4734) Add table option to copy sink --- .../v2018_06_01/AvroCompressionCodec.java | 50 +++++++++ .../datafactory/v2018_06_01/AvroDataset.java | 102 ++++++++++++++++++ .../datafactory/v2018_06_01/AvroSink.java | 73 +++++++++++++ .../datafactory/v2018_06_01/AvroSource.java | 47 ++++++++ .../v2018_06_01/AvroWriteSettings.java | 69 ++++++++++++ .../datafactory/v2018_06_01/CopySink.java | 29 +++++ .../datafactory/v2018_06_01/CopySource.java | 3 +- .../v2018_06_01/Office365Source.java | 6 +- .../implementation/DatasetInner.java | 1 + 9 files changed, 376 insertions(+), 4 deletions(-) create mode 100644 datafactory/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AvroCompressionCodec.java create mode 100644 datafactory/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AvroDataset.java create mode 100644 datafactory/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AvroSink.java create mode 100644 datafactory/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AvroSource.java create mode 100644 datafactory/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AvroWriteSettings.java diff --git a/datafactory/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AvroCompressionCodec.java b/datafactory/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AvroCompressionCodec.java new file mode 100644 index 0000000000000..bc2e43f668aa6 --- /dev/null +++ b/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 { + /** 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 values() { + return values(AvroCompressionCodec.class); + } +} diff --git a/datafactory/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AvroDataset.java b/datafactory/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AvroDataset.java new file mode 100644 index 0000000000000..0fdcc0c97588d --- /dev/null +++ b/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; + } + +} diff --git a/datafactory/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AvroSink.java b/datafactory/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AvroSink.java new file mode 100644 index 0000000000000..b38046dd1ae12 --- /dev/null +++ b/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; + } + +} diff --git a/datafactory/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AvroSource.java b/datafactory/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AvroSource.java new file mode 100644 index 0000000000000..b4056b7a9021e --- /dev/null +++ b/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; + } + +} diff --git a/datafactory/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AvroWriteSettings.java b/datafactory/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AvroWriteSettings.java new file mode 100644 index 0000000000000..ba08956f64c2b --- /dev/null +++ b/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; + } + +} diff --git a/datafactory/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CopySink.java b/datafactory/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CopySink.java index c15987f812a83..1be631fafbcfe 100644 --- a/datafactory/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CopySink.java +++ b/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; + } + } diff --git a/datafactory/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CopySource.java b/datafactory/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CopySource.java index 6cd0cad90e2bb..f46451e5ab22d 100644 --- a/datafactory/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CopySource.java +++ b/datafactory/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CopySource.java @@ -101,7 +101,8 @@ @JsonSubTypes.Type(name = "AzureTableSource", value = AzureTableSource.class), @JsonSubTypes.Type(name = "BinarySource", value = BinarySource.class), @JsonSubTypes.Type(name = "DelimitedTextSource", value = DelimitedTextSource.class), - @JsonSubTypes.Type(name = "ParquetSource", value = ParquetSource.class) + @JsonSubTypes.Type(name = "ParquetSource", value = ParquetSource.class), + @JsonSubTypes.Type(name = "AvroSource", value = AvroSource.class) }) public class CopySource { /** diff --git a/datafactory/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/Office365Source.java b/datafactory/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/Office365Source.java index 3f15d7fb5424b..9150d87be57ad 100644 --- a/datafactory/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/Office365Source.java +++ b/datafactory/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/Office365Source.java @@ -47,7 +47,7 @@ public class Office365Source extends CopySource { private Object startTime; /** - * End time of the requested range for thsi dataset. Type: string (or + * End time of the requested range for this dataset. Type: string (or * Expression with resultType string). */ @JsonProperty(value = "endTime") @@ -134,7 +134,7 @@ public Office365Source withStartTime(Object startTime) { } /** - * Get end time of the requested range for thsi dataset. Type: string (or Expression with resultType string). + * Get end time of the requested range for this dataset. Type: string (or Expression with resultType string). * * @return the endTime value */ @@ -143,7 +143,7 @@ public Object endTime() { } /** - * Set end time of the requested range for thsi dataset. Type: string (or Expression with resultType string). + * Set end time of the requested range for this dataset. Type: string (or Expression with resultType string). * * @param endTime the endTime value to set * @return the Office365Source object itself. diff --git a/datafactory/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/DatasetInner.java b/datafactory/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/DatasetInner.java index 33b6aa3da2272..a8993e47bf624 100644 --- a/datafactory/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/DatasetInner.java +++ b/datafactory/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/DatasetInner.java @@ -105,6 +105,7 @@ @JsonSubTypes.Type(name = "Binary", value = BinaryDataset.class), @JsonSubTypes.Type(name = "DelimitedText", value = DelimitedTextDataset.class), @JsonSubTypes.Type(name = "Parquet", value = ParquetDataset.class), + @JsonSubTypes.Type(name = "Avro", value = AvroDataset.class), @JsonSubTypes.Type(name = "AmazonS3Object", value = AmazonS3Dataset.class) }) public class DatasetInner {