diff --git a/sdk/datafactory/mgmt-v2018_06_01/pom.xml b/sdk/datafactory/mgmt-v2018_06_01/pom.xml index 79145c162701..6a01bee79fc6 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/pom.xml +++ b/sdk/datafactory/mgmt-v2018_06_01/pom.xml @@ -11,11 +11,11 @@ com.microsoft.azure azure-arm-parent - 1.3.2 - ../../parents/azure-arm-parent/pom.xml + 1.1.0 + ../../../pom.management.xml azure-mgmt-datafactory - 1.0.0-beta-4 + 1.0.0-beta jar Microsoft Azure SDK for DataFactory Management This package contains Microsoft DataFactory Management SDK. diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AvroWriteSettings.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AvroWriteSettings.java index 9ee2f49222dd..139c2b133b0b 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AvroWriteSettings.java +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AvroWriteSettings.java @@ -30,6 +30,22 @@ public class AvroWriteSettings extends FormatWriteSettings { @JsonProperty(value = "recordNamespace") private String recordNamespace; + /** + * Limit the written file's row count to be smaller than or equal to the + * specified count. Type: integer (or Expression with resultType integer). + */ + @JsonProperty(value = "maxRowsPerFile") + private Object maxRowsPerFile; + + /** + * Specifies the file name pattern + * <fileNamePrefix>_<fileIndex>.<fileExtension> when copy + * from non-file based store without partitionOptions. Type: string (or + * Expression with resultType string). + */ + @JsonProperty(value = "fileNamePrefix") + private Object fileNamePrefix; + /** * Get top level record name in write result, which is required in AVRO spec. * @@ -70,4 +86,44 @@ public AvroWriteSettings withRecordNamespace(String recordNamespace) { return this; } + /** + * Get limit the written file's row count to be smaller than or equal to the specified count. Type: integer (or Expression with resultType integer). + * + * @return the maxRowsPerFile value + */ + public Object maxRowsPerFile() { + return this.maxRowsPerFile; + } + + /** + * Set limit the written file's row count to be smaller than or equal to the specified count. Type: integer (or Expression with resultType integer). + * + * @param maxRowsPerFile the maxRowsPerFile value to set + * @return the AvroWriteSettings object itself. + */ + public AvroWriteSettings withMaxRowsPerFile(Object maxRowsPerFile) { + this.maxRowsPerFile = maxRowsPerFile; + return this; + } + + /** + * Get specifies the file name pattern <fileNamePrefix>_<fileIndex>.<fileExtension> when copy from non-file based store without partitionOptions. Type: string (or Expression with resultType string). + * + * @return the fileNamePrefix value + */ + public Object fileNamePrefix() { + return this.fileNamePrefix; + } + + /** + * Set specifies the file name pattern <fileNamePrefix>_<fileIndex>.<fileExtension> when copy from non-file based store without partitionOptions. Type: string (or Expression with resultType string). + * + * @param fileNamePrefix the fileNamePrefix value to set + * @return the AvroWriteSettings object itself. + */ + public AvroWriteSettings withFileNamePrefix(Object fileNamePrefix) { + this.fileNamePrefix = fileNamePrefix; + return this; + } + } diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureDatabricksDeltaLakeDataset.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureDatabricksDeltaLakeDataset.java new file mode 100644 index 000000000000..71356c18401f --- /dev/null +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureDatabricksDeltaLakeDataset.java @@ -0,0 +1,78 @@ +/** + * 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; + +/** + * Azure Databricks Delta Lake dataset. + */ +@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type", defaultImpl = AzureDatabricksDeltaLakeDataset.class) +@JsonTypeName("AzureDatabricksDeltaLakeDataset") +@JsonFlatten +public class AzureDatabricksDeltaLakeDataset extends DatasetInner { + /** + * The name of delta table. Type: string (or Expression with resultType + * string). + */ + @JsonProperty(value = "typeProperties.table") + private Object table; + + /** + * The database name of delta table. Type: string (or Expression with + * resultType string). + */ + @JsonProperty(value = "typeProperties.database") + private Object database; + + /** + * Get the name of delta table. Type: string (or Expression with resultType string). + * + * @return the table value + */ + public Object table() { + return this.table; + } + + /** + * Set the name of delta table. Type: string (or Expression with resultType string). + * + * @param table the table value to set + * @return the AzureDatabricksDeltaLakeDataset object itself. + */ + public AzureDatabricksDeltaLakeDataset withTable(Object table) { + this.table = table; + return this; + } + + /** + * Get the database name of delta table. Type: string (or Expression with resultType string). + * + * @return the database value + */ + public Object database() { + return this.database; + } + + /** + * Set the database name of delta table. Type: string (or Expression with resultType string). + * + * @param database the database value to set + * @return the AzureDatabricksDeltaLakeDataset object itself. + */ + public AzureDatabricksDeltaLakeDataset withDatabase(Object database) { + this.database = database; + return this; + } + +} diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureDatabricksDeltaLakeExportCommand.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureDatabricksDeltaLakeExportCommand.java new file mode 100644 index 000000000000..b386c0ac71e0 --- /dev/null +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureDatabricksDeltaLakeExportCommand.java @@ -0,0 +1,75 @@ +/** + * 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; + +/** + * Azure Databricks Delta Lake export command settings. + */ +@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type", defaultImpl = AzureDatabricksDeltaLakeExportCommand.class) +@JsonTypeName("AzureDatabricksDeltaLakeExportCommand") +public class AzureDatabricksDeltaLakeExportCommand extends ExportSettings { + /** + * Specify the date format for the csv in Azure Databricks Delta Lake Copy. + * Type: string (or Expression with resultType string). + */ + @JsonProperty(value = "dateFormat") + private Object dateFormat; + + /** + * Specify the timestamp format for the csv in Azure Databricks Delta Lake + * Copy. Type: string (or Expression with resultType string). + */ + @JsonProperty(value = "timestampFormat") + private Object timestampFormat; + + /** + * Get specify the date format for the csv in Azure Databricks Delta Lake Copy. Type: string (or Expression with resultType string). + * + * @return the dateFormat value + */ + public Object dateFormat() { + return this.dateFormat; + } + + /** + * Set specify the date format for the csv in Azure Databricks Delta Lake Copy. Type: string (or Expression with resultType string). + * + * @param dateFormat the dateFormat value to set + * @return the AzureDatabricksDeltaLakeExportCommand object itself. + */ + public AzureDatabricksDeltaLakeExportCommand withDateFormat(Object dateFormat) { + this.dateFormat = dateFormat; + return this; + } + + /** + * Get specify the timestamp format for the csv in Azure Databricks Delta Lake Copy. Type: string (or Expression with resultType string). + * + * @return the timestampFormat value + */ + public Object timestampFormat() { + return this.timestampFormat; + } + + /** + * Set specify the timestamp format for the csv in Azure Databricks Delta Lake Copy. Type: string (or Expression with resultType string). + * + * @param timestampFormat the timestampFormat value to set + * @return the AzureDatabricksDeltaLakeExportCommand object itself. + */ + public AzureDatabricksDeltaLakeExportCommand withTimestampFormat(Object timestampFormat) { + this.timestampFormat = timestampFormat; + return this; + } + +} diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureDatabricksDeltaLakeImportCommand.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureDatabricksDeltaLakeImportCommand.java new file mode 100644 index 000000000000..662ab070e1fc --- /dev/null +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureDatabricksDeltaLakeImportCommand.java @@ -0,0 +1,75 @@ +/** + * 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; + +/** + * Azure Databricks Delta Lake import command settings. + */ +@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type", defaultImpl = AzureDatabricksDeltaLakeImportCommand.class) +@JsonTypeName("AzureDatabricksDeltaLakeImportCommand") +public class AzureDatabricksDeltaLakeImportCommand extends ImportSettings { + /** + * Specify the date format for csv in Azure Databricks Delta Lake Copy. + * Type: string (or Expression with resultType string). + */ + @JsonProperty(value = "dateFormat") + private Object dateFormat; + + /** + * Specify the timestamp format for csv in Azure Databricks Delta Lake + * Copy. Type: string (or Expression with resultType string). + */ + @JsonProperty(value = "timestampFormat") + private Object timestampFormat; + + /** + * Get specify the date format for csv in Azure Databricks Delta Lake Copy. Type: string (or Expression with resultType string). + * + * @return the dateFormat value + */ + public Object dateFormat() { + return this.dateFormat; + } + + /** + * Set specify the date format for csv in Azure Databricks Delta Lake Copy. Type: string (or Expression with resultType string). + * + * @param dateFormat the dateFormat value to set + * @return the AzureDatabricksDeltaLakeImportCommand object itself. + */ + public AzureDatabricksDeltaLakeImportCommand withDateFormat(Object dateFormat) { + this.dateFormat = dateFormat; + return this; + } + + /** + * Get specify the timestamp format for csv in Azure Databricks Delta Lake Copy. Type: string (or Expression with resultType string). + * + * @return the timestampFormat value + */ + public Object timestampFormat() { + return this.timestampFormat; + } + + /** + * Set specify the timestamp format for csv in Azure Databricks Delta Lake Copy. Type: string (or Expression with resultType string). + * + * @param timestampFormat the timestampFormat value to set + * @return the AzureDatabricksDeltaLakeImportCommand object itself. + */ + public AzureDatabricksDeltaLakeImportCommand withTimestampFormat(Object timestampFormat) { + this.timestampFormat = timestampFormat; + return this; + } + +} diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureDatabricksDeltaLakeLinkedService.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureDatabricksDeltaLakeLinkedService.java new file mode 100644 index 000000000000..ca66d080f43c --- /dev/null +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureDatabricksDeltaLakeLinkedService.java @@ -0,0 +1,134 @@ +/** + * 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.LinkedServiceInner; + +/** + * Azure Databricks Delta Lake linked service. + */ +@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type", defaultImpl = AzureDatabricksDeltaLakeLinkedService.class) +@JsonTypeName("AzureDatabricksDeltaLake") +@JsonFlatten +public class AzureDatabricksDeltaLakeLinkedService extends LinkedServiceInner { + /** + * <REGION>.azuredatabricks.net, domain name of your Databricks + * deployment. Type: string (or Expression with resultType string). + */ + @JsonProperty(value = "typeProperties.domain", required = true) + private Object domain; + + /** + * Access token for databricks REST API. Refer to + * https://docs.azuredatabricks.net/api/latest/authentication.html. Type: + * string, SecureString or AzureKeyVaultSecretReference. + */ + @JsonProperty(value = "typeProperties.accessToken") + private SecretBase accessToken; + + /** + * The id of an existing interactive cluster that will be used for all runs + * of this job. Type: string (or Expression with resultType string). + */ + @JsonProperty(value = "typeProperties.clusterId") + private Object clusterId; + + /** + * The encrypted credential used for authentication. Credentials are + * encrypted using the integration runtime credential manager. Type: string + * (or Expression with resultType string). + */ + @JsonProperty(value = "typeProperties.encryptedCredential") + private Object encryptedCredential; + + /** + * Get <REGION>.azuredatabricks.net, domain name of your Databricks deployment. Type: string (or Expression with resultType string). + * + * @return the domain value + */ + public Object domain() { + return this.domain; + } + + /** + * Set <REGION>.azuredatabricks.net, domain name of your Databricks deployment. Type: string (or Expression with resultType string). + * + * @param domain the domain value to set + * @return the AzureDatabricksDeltaLakeLinkedService object itself. + */ + public AzureDatabricksDeltaLakeLinkedService withDomain(Object domain) { + this.domain = domain; + return this; + } + + /** + * Get access token for databricks REST API. Refer to https://docs.azuredatabricks.net/api/latest/authentication.html. Type: string, SecureString or AzureKeyVaultSecretReference. + * + * @return the accessToken value + */ + public SecretBase accessToken() { + return this.accessToken; + } + + /** + * Set access token for databricks REST API. Refer to https://docs.azuredatabricks.net/api/latest/authentication.html. Type: string, SecureString or AzureKeyVaultSecretReference. + * + * @param accessToken the accessToken value to set + * @return the AzureDatabricksDeltaLakeLinkedService object itself. + */ + public AzureDatabricksDeltaLakeLinkedService withAccessToken(SecretBase accessToken) { + this.accessToken = accessToken; + return this; + } + + /** + * Get the id of an existing interactive cluster that will be used for all runs of this job. Type: string (or Expression with resultType string). + * + * @return the clusterId value + */ + public Object clusterId() { + return this.clusterId; + } + + /** + * Set the id of an existing interactive cluster that will be used for all runs of this job. Type: string (or Expression with resultType string). + * + * @param clusterId the clusterId value to set + * @return the AzureDatabricksDeltaLakeLinkedService object itself. + */ + public AzureDatabricksDeltaLakeLinkedService withClusterId(Object clusterId) { + this.clusterId = clusterId; + return this; + } + + /** + * Get the encrypted credential used for authentication. Credentials are encrypted using the integration runtime credential manager. Type: string (or Expression with resultType string). + * + * @return the encryptedCredential value + */ + public Object encryptedCredential() { + return this.encryptedCredential; + } + + /** + * Set the encrypted credential used for authentication. Credentials are encrypted using the integration runtime credential manager. Type: string (or Expression with resultType string). + * + * @param encryptedCredential the encryptedCredential value to set + * @return the AzureDatabricksDeltaLakeLinkedService object itself. + */ + public AzureDatabricksDeltaLakeLinkedService withEncryptedCredential(Object encryptedCredential) { + this.encryptedCredential = encryptedCredential; + return this; + } + +} diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureDatabricksDeltaLakeSink.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureDatabricksDeltaLakeSink.java new file mode 100644 index 000000000000..265ff4e0a7f0 --- /dev/null +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureDatabricksDeltaLakeSink.java @@ -0,0 +1,74 @@ +/** + * 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 Azure Databricks Delta Lake sink. + */ +@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type", defaultImpl = AzureDatabricksDeltaLakeSink.class) +@JsonTypeName("AzureDatabricksDeltaLakeSink") +public class AzureDatabricksDeltaLakeSink extends CopySink { + /** + * SQL pre-copy script. Type: string (or Expression with resultType + * string). + */ + @JsonProperty(value = "preCopyScript") + private Object preCopyScript; + + /** + * Azure Databricks Delta Lake import settings. + */ + @JsonProperty(value = "importSettings") + private AzureDatabricksDeltaLakeImportCommand importSettings; + + /** + * Get sQL pre-copy script. Type: string (or Expression with resultType string). + * + * @return the preCopyScript value + */ + public Object preCopyScript() { + return this.preCopyScript; + } + + /** + * Set sQL pre-copy script. Type: string (or Expression with resultType string). + * + * @param preCopyScript the preCopyScript value to set + * @return the AzureDatabricksDeltaLakeSink object itself. + */ + public AzureDatabricksDeltaLakeSink withPreCopyScript(Object preCopyScript) { + this.preCopyScript = preCopyScript; + return this; + } + + /** + * Get azure Databricks Delta Lake import settings. + * + * @return the importSettings value + */ + public AzureDatabricksDeltaLakeImportCommand importSettings() { + return this.importSettings; + } + + /** + * Set azure Databricks Delta Lake import settings. + * + * @param importSettings the importSettings value to set + * @return the AzureDatabricksDeltaLakeSink object itself. + */ + public AzureDatabricksDeltaLakeSink withImportSettings(AzureDatabricksDeltaLakeImportCommand importSettings) { + this.importSettings = importSettings; + return this; + } + +} diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureDatabricksDeltaLakeSource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureDatabricksDeltaLakeSource.java new file mode 100644 index 000000000000..4aead2be4e2d --- /dev/null +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureDatabricksDeltaLakeSource.java @@ -0,0 +1,74 @@ +/** + * 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 Azure Databricks Delta Lake source. + */ +@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type", defaultImpl = AzureDatabricksDeltaLakeSource.class) +@JsonTypeName("AzureDatabricksDeltaLakeSource") +public class AzureDatabricksDeltaLakeSource extends CopySource { + /** + * Azure Databricks Delta Lake Sql query. Type: string (or Expression with + * resultType string). + */ + @JsonProperty(value = "query") + private Object query; + + /** + * Azure Databricks Delta Lake export settings. + */ + @JsonProperty(value = "exportSettings") + private AzureDatabricksDeltaLakeExportCommand exportSettings; + + /** + * Get azure Databricks Delta Lake Sql query. Type: string (or Expression with resultType string). + * + * @return the query value + */ + public Object query() { + return this.query; + } + + /** + * Set azure Databricks Delta Lake Sql query. Type: string (or Expression with resultType string). + * + * @param query the query value to set + * @return the AzureDatabricksDeltaLakeSource object itself. + */ + public AzureDatabricksDeltaLakeSource withQuery(Object query) { + this.query = query; + return this; + } + + /** + * Get azure Databricks Delta Lake export settings. + * + * @return the exportSettings value + */ + public AzureDatabricksDeltaLakeExportCommand exportSettings() { + return this.exportSettings; + } + + /** + * Set azure Databricks Delta Lake export settings. + * + * @param exportSettings the exportSettings value to set + * @return the AzureDatabricksDeltaLakeSource object itself. + */ + public AzureDatabricksDeltaLakeSource withExportSettings(AzureDatabricksDeltaLakeExportCommand exportSettings) { + this.exportSettings = exportSettings; + return this; + } + +} diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CompressionReadSettings.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CompressionReadSettings.java index 0ccdda9e7359..f4f19174ce56 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CompressionReadSettings.java +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CompressionReadSettings.java @@ -20,6 +20,8 @@ @JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type", defaultImpl = CompressionReadSettings.class) @JsonTypeName("CompressionReadSettings") @JsonSubTypes({ + @JsonSubTypes.Type(name = "TarGZipReadSettings", value = TarGZipReadSettings.class), + @JsonSubTypes.Type(name = "TarReadSettings", value = TarReadSettings.class), @JsonSubTypes.Type(name = "ZipDeflateReadSettings", value = ZipDeflateReadSettings.class) }) public class CompressionReadSettings { diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CopyBehaviorType.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CopyBehaviorType.java new file mode 100644 index 000000000000..ce5e8fb60926 --- /dev/null +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CopyBehaviorType.java @@ -0,0 +1,44 @@ +/** + * 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 CopyBehaviorType. + */ +public final class CopyBehaviorType extends ExpandableStringEnum { + /** Static value PreserveHierarchy for CopyBehaviorType. */ + public static final CopyBehaviorType PRESERVE_HIERARCHY = fromString("PreserveHierarchy"); + + /** Static value FlattenHierarchy for CopyBehaviorType. */ + public static final CopyBehaviorType FLATTEN_HIERARCHY = fromString("FlattenHierarchy"); + + /** Static value MergeFiles for CopyBehaviorType. */ + public static final CopyBehaviorType MERGE_FILES = fromString("MergeFiles"); + + /** + * Creates or finds a CopyBehaviorType from its string representation. + * @param name a name to look for + * @return the corresponding CopyBehaviorType + */ + @JsonCreator + public static CopyBehaviorType fromString(String name) { + return fromString(name, CopyBehaviorType.class); + } + + /** + * @return known CopyBehaviorType values + */ + public static Collection values() { + return values(CopyBehaviorType.class); + } +} diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CopySink.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CopySink.java index b836d597cfaa..45d20e2a274a 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CopySink.java +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CopySink.java @@ -50,6 +50,7 @@ @JsonSubTypes.Type(name = "AzureTableSink", value = AzureTableSink.class), @JsonSubTypes.Type(name = "AzureQueueSink", value = AzureQueueSink.class), @JsonSubTypes.Type(name = "SapCloudForCustomerSink", value = SapCloudForCustomerSink.class), + @JsonSubTypes.Type(name = "AzureDatabricksDeltaLakeSink", value = AzureDatabricksDeltaLakeSink.class), @JsonSubTypes.Type(name = "AzureMySqlSink", value = AzureMySqlSink.class), @JsonSubTypes.Type(name = "AzurePostgreSqlSink", value = AzurePostgreSqlSink.class), @JsonSubTypes.Type(name = "RestSink", value = RestSink.class), diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CopySource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CopySource.java index 70aa6f0a01f5..31d7ff076c9b 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CopySource.java +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CopySource.java @@ -21,6 +21,7 @@ @JsonTypeName("CopySource") @JsonSubTypes({ @JsonSubTypes.Type(name = "SharePointOnlineListSource", value = SharePointOnlineListSource.class), + @JsonSubTypes.Type(name = "AzureDatabricksDeltaLakeSource", value = AzureDatabricksDeltaLakeSource.class), @JsonSubTypes.Type(name = "SnowflakeSource", value = SnowflakeSource.class), @JsonSubTypes.Type(name = "HttpSource", value = HttpSource.class), @JsonSubTypes.Type(name = "AzureBlobFSSource", value = AzureBlobFSSource.class), @@ -28,6 +29,7 @@ @JsonSubTypes.Type(name = "Office365Source", value = Office365Source.class), @JsonSubTypes.Type(name = "CosmosDbMongoDbApiSource", value = CosmosDbMongoDbApiSource.class), @JsonSubTypes.Type(name = "MongoDbV2Source", value = MongoDbV2Source.class), + @JsonSubTypes.Type(name = "MongoDbAtlasSource", value = MongoDbAtlasSource.class), @JsonSubTypes.Type(name = "MongoDbSource", value = MongoDbSource.class), @JsonSubTypes.Type(name = "WebSource", value = WebSource.class), @JsonSubTypes.Type(name = "OracleSource", value = OracleSource.class), diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CopyTranslator.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CopyTranslator.java new file mode 100644 index 000000000000..e03ffce3ff71 --- /dev/null +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CopyTranslator.java @@ -0,0 +1,52 @@ +/** + * 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.Map; +import com.fasterxml.jackson.annotation.JsonProperty; +import com.fasterxml.jackson.annotation.JsonTypeInfo; +import com.fasterxml.jackson.annotation.JsonTypeName; +import com.fasterxml.jackson.annotation.JsonSubTypes; + +/** + * A copy activity translator. + */ +@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type", defaultImpl = CopyTranslator.class) +@JsonTypeName("CopyTranslator") +@JsonSubTypes({ + @JsonSubTypes.Type(name = "TabularTranslator", value = TabularTranslator.class) +}) +public class CopyTranslator { + /** + * Unmatched properties from the message are deserialized this collection. + */ + @JsonProperty(value = "") + private Map additionalProperties; + + /** + * Get unmatched properties from the message are deserialized this collection. + * + * @return the additionalProperties value + */ + public Map additionalProperties() { + return this.additionalProperties; + } + + /** + * Set unmatched properties from the message are deserialized this collection. + * + * @param additionalProperties the additionalProperties value to set + * @return the CopyTranslator object itself. + */ + public CopyTranslator withAdditionalProperties(Map additionalProperties) { + this.additionalProperties = additionalProperties; + return this; + } + +} diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DatasetCompression.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DatasetCompression.java index af32c35330c0..d51259d1d8ef 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DatasetCompression.java +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DatasetCompression.java @@ -20,6 +20,8 @@ @JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type", defaultImpl = DatasetCompression.class) @JsonTypeName("DatasetCompression") @JsonSubTypes({ + @JsonSubTypes.Type(name = "TarGZip", value = DatasetTarGZipCompression.class), + @JsonSubTypes.Type(name = "Tar", value = DatasetTarCompression.class), @JsonSubTypes.Type(name = "ZipDeflate", value = DatasetZipDeflateCompression.class), @JsonSubTypes.Type(name = "Deflate", value = DatasetDeflateCompression.class), @JsonSubTypes.Type(name = "GZip", value = DatasetGZipCompression.class), diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DatasetDataElement.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DatasetDataElement.java new file mode 100644 index 000000000000..c21fb7c5d55f --- /dev/null +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DatasetDataElement.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; + +/** + * Columns that define the structure of the dataset. + */ +public class DatasetDataElement { + /** + * Name of the column. Type: string (or Expression with resultType string). + */ + @JsonProperty(value = "name") + private Object name; + + /** + * Type of the column. Type: string (or Expression with resultType string). + */ + @JsonProperty(value = "type") + private Object type; + + /** + * Get name of the column. Type: string (or Expression with resultType string). + * + * @return the name value + */ + public Object name() { + return this.name; + } + + /** + * Set name of the column. Type: string (or Expression with resultType string). + * + * @param name the name value to set + * @return the DatasetDataElement object itself. + */ + public DatasetDataElement withName(Object name) { + this.name = name; + return this; + } + + /** + * Get type of the column. Type: string (or Expression with resultType string). + * + * @return the type value + */ + public Object type() { + return this.type; + } + + /** + * Set type of the column. Type: string (or Expression with resultType string). + * + * @param type the type value to set + * @return the DatasetDataElement object itself. + */ + public DatasetDataElement withType(Object type) { + this.type = type; + return this; + } + +} diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DatasetSchemaDataElement.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DatasetSchemaDataElement.java new file mode 100644 index 000000000000..309d1384a396 --- /dev/null +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DatasetSchemaDataElement.java @@ -0,0 +1,98 @@ +/** + * 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.Map; +import com.fasterxml.jackson.annotation.JsonProperty; + +/** + * Columns that define the physical type schema of the dataset. + */ +public class DatasetSchemaDataElement { + /** + * Unmatched properties from the message are deserialized this collection. + */ + @JsonProperty(value = "") + private Map additionalProperties; + + /** + * Name of the schema column. Type: string (or Expression with resultType + * string). + */ + @JsonProperty(value = "name") + private Object name; + + /** + * Type of the schema column. Type: string (or Expression with resultType + * string). + */ + @JsonProperty(value = "type") + private Object type; + + /** + * Get unmatched properties from the message are deserialized this collection. + * + * @return the additionalProperties value + */ + public Map additionalProperties() { + return this.additionalProperties; + } + + /** + * Set unmatched properties from the message are deserialized this collection. + * + * @param additionalProperties the additionalProperties value to set + * @return the DatasetSchemaDataElement object itself. + */ + public DatasetSchemaDataElement withAdditionalProperties(Map additionalProperties) { + this.additionalProperties = additionalProperties; + return this; + } + + /** + * Get name of the schema column. Type: string (or Expression with resultType string). + * + * @return the name value + */ + public Object name() { + return this.name; + } + + /** + * Set name of the schema column. Type: string (or Expression with resultType string). + * + * @param name the name value to set + * @return the DatasetSchemaDataElement object itself. + */ + public DatasetSchemaDataElement withName(Object name) { + this.name = name; + return this; + } + + /** + * Get type of the schema column. Type: string (or Expression with resultType string). + * + * @return the type value + */ + public Object type() { + return this.type; + } + + /** + * Set type of the schema column. Type: string (or Expression with resultType string). + * + * @param type the type value to set + * @return the DatasetSchemaDataElement object itself. + */ + public DatasetSchemaDataElement withType(Object type) { + this.type = type; + return this; + } + +} diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DatasetTarCompression.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DatasetTarCompression.java new file mode 100644 index 000000000000..3b8499ad7434 --- /dev/null +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DatasetTarCompression.java @@ -0,0 +1,20 @@ +/** + * 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.JsonTypeInfo; +import com.fasterxml.jackson.annotation.JsonTypeName; + +/** + * The Tar archive method used on a dataset. + */ +@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type", defaultImpl = DatasetTarCompression.class) +@JsonTypeName("Tar") +public class DatasetTarCompression extends DatasetCompression { +} diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DatasetTarGZipCompression.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DatasetTarGZipCompression.java new file mode 100644 index 000000000000..b593bd54a84b --- /dev/null +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DatasetTarGZipCompression.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; + +/** + * The TarGZip compression method used on a dataset. + */ +@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type", defaultImpl = DatasetTarGZipCompression.class) +@JsonTypeName("TarGZip") +public class DatasetTarGZipCompression extends DatasetCompression { + /** + * The TarGZip compression level. + */ + @JsonProperty(value = "level") + private Object level; + + /** + * Get the TarGZip compression level. + * + * @return the level value + */ + public Object level() { + return this.level; + } + + /** + * Set the TarGZip compression level. + * + * @param level the level value to set + * @return the DatasetTarGZipCompression object itself. + */ + public DatasetTarGZipCompression withLevel(Object level) { + this.level = level; + return this; + } + +} diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DelimitedTextWriteSettings.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DelimitedTextWriteSettings.java index b3053dda4382..1ab0f30b3c04 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DelimitedTextWriteSettings.java +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DelimitedTextWriteSettings.java @@ -32,6 +32,22 @@ public class DelimitedTextWriteSettings extends FormatWriteSettings { @JsonProperty(value = "fileExtension", required = true) private Object fileExtension; + /** + * Limit the written file's row count to be smaller than or equal to the + * specified count. Type: integer (or Expression with resultType integer). + */ + @JsonProperty(value = "maxRowsPerFile") + private Object maxRowsPerFile; + + /** + * Specifies the file name pattern + * <fileNamePrefix>_<fileIndex>.<fileExtension> when copy + * from non-file based store without partitionOptions. Type: string (or + * Expression with resultType string). + */ + @JsonProperty(value = "fileNamePrefix") + private Object fileNamePrefix; + /** * Get indicates whether string values should always be enclosed with quotes. Type: boolean (or Expression with resultType boolean). * @@ -72,4 +88,44 @@ public DelimitedTextWriteSettings withFileExtension(Object fileExtension) { return this; } + /** + * Get limit the written file's row count to be smaller than or equal to the specified count. Type: integer (or Expression with resultType integer). + * + * @return the maxRowsPerFile value + */ + public Object maxRowsPerFile() { + return this.maxRowsPerFile; + } + + /** + * Set limit the written file's row count to be smaller than or equal to the specified count. Type: integer (or Expression with resultType integer). + * + * @param maxRowsPerFile the maxRowsPerFile value to set + * @return the DelimitedTextWriteSettings object itself. + */ + public DelimitedTextWriteSettings withMaxRowsPerFile(Object maxRowsPerFile) { + this.maxRowsPerFile = maxRowsPerFile; + return this; + } + + /** + * Get specifies the file name pattern <fileNamePrefix>_<fileIndex>.<fileExtension> when copy from non-file based store without partitionOptions. Type: string (or Expression with resultType string). + * + * @return the fileNamePrefix value + */ + public Object fileNamePrefix() { + return this.fileNamePrefix; + } + + /** + * Set specifies the file name pattern <fileNamePrefix>_<fileIndex>.<fileExtension> when copy from non-file based store without partitionOptions. Type: string (or Expression with resultType string). + * + * @param fileNamePrefix the fileNamePrefix value to set + * @return the DelimitedTextWriteSettings object itself. + */ + public DelimitedTextWriteSettings withFileNamePrefix(Object fileNamePrefix) { + this.fileNamePrefix = fileNamePrefix; + return this; + } + } diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DynamicsSinkWriteBehavior.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DynamicsSinkWriteBehavior.java new file mode 100644 index 000000000000..3e6e74a59276 --- /dev/null +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DynamicsSinkWriteBehavior.java @@ -0,0 +1,38 @@ +/** + * 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 DynamicsSinkWriteBehavior. + */ +public final class DynamicsSinkWriteBehavior extends ExpandableStringEnum { + /** Static value Upsert for DynamicsSinkWriteBehavior. */ + public static final DynamicsSinkWriteBehavior UPSERT = fromString("Upsert"); + + /** + * Creates or finds a DynamicsSinkWriteBehavior from its string representation. + * @param name a name to look for + * @return the corresponding DynamicsSinkWriteBehavior + */ + @JsonCreator + public static DynamicsSinkWriteBehavior fromString(String name) { + return fromString(name, DynamicsSinkWriteBehavior.class); + } + + /** + * @return known DynamicsSinkWriteBehavior values + */ + public static Collection values() { + return values(DynamicsSinkWriteBehavior.class); + } +} diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/ExportSettings.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/ExportSettings.java index 6f322b480f3f..224b3d70716f 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/ExportSettings.java +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/ExportSettings.java @@ -20,7 +20,8 @@ @JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type", defaultImpl = ExportSettings.class) @JsonTypeName("ExportSettings") @JsonSubTypes({ - @JsonSubTypes.Type(name = "SnowflakeExportCopyCommand", value = SnowflakeExportCopyCommand.class) + @JsonSubTypes.Type(name = "SnowflakeExportCopyCommand", value = SnowflakeExportCopyCommand.class), + @JsonSubTypes.Type(name = "AzureDatabricksDeltaLakeExportCommand", value = AzureDatabricksDeltaLakeExportCommand.class) }) public class ExportSettings { /** diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/FormatWriteSettings.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/FormatWriteSettings.java index e02e45114173..b40ad1a07604 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/FormatWriteSettings.java +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/FormatWriteSettings.java @@ -22,7 +22,9 @@ @JsonSubTypes({ @JsonSubTypes.Type(name = "JsonWriteSettings", value = JsonWriteSettings.class), @JsonSubTypes.Type(name = "DelimitedTextWriteSettings", value = DelimitedTextWriteSettings.class), - @JsonSubTypes.Type(name = "AvroWriteSettings", value = AvroWriteSettings.class) + @JsonSubTypes.Type(name = "OrcWriteSettings", value = OrcWriteSettings.class), + @JsonSubTypes.Type(name = "AvroWriteSettings", value = AvroWriteSettings.class), + @JsonSubTypes.Type(name = "ParquetWriteSettings", value = ParquetWriteSettings.class) }) public class FormatWriteSettings { /** diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/ImportSettings.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/ImportSettings.java index a6ce0f622205..0f62934e4371 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/ImportSettings.java +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/ImportSettings.java @@ -20,6 +20,7 @@ @JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type", defaultImpl = ImportSettings.class) @JsonTypeName("ImportSettings") @JsonSubTypes({ + @JsonSubTypes.Type(name = "AzureDatabricksDeltaLakeImportCommand", value = AzureDatabricksDeltaLakeImportCommand.class), @JsonSubTypes.Type(name = "SnowflakeImportCopyCommand", value = SnowflakeImportCopyCommand.class) }) public class ImportSettings { diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/LogStorageSettings.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/LogStorageSettings.java index 710cdce199e7..a9abe562e5a4 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/LogStorageSettings.java +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/LogStorageSettings.java @@ -34,6 +34,20 @@ public class LogStorageSettings { @JsonProperty(value = "path") private Object path; + /** + * Gets or sets the log level, support: Info, Warning. Type: string (or + * Expression with resultType string). + */ + @JsonProperty(value = "logLevel") + private Object logLevel; + + /** + * Specifies whether to enable reliable logging. Type: boolean (or + * Expression with resultType boolean). + */ + @JsonProperty(value = "enableReliableLogging") + private Object enableReliableLogging; + /** * Get unmatched properties from the message are deserialized this collection. * @@ -94,4 +108,44 @@ public LogStorageSettings withPath(Object path) { return this; } + /** + * Get gets or sets the log level, support: Info, Warning. Type: string (or Expression with resultType string). + * + * @return the logLevel value + */ + public Object logLevel() { + return this.logLevel; + } + + /** + * Set gets or sets the log level, support: Info, Warning. Type: string (or Expression with resultType string). + * + * @param logLevel the logLevel value to set + * @return the LogStorageSettings object itself. + */ + public LogStorageSettings withLogLevel(Object logLevel) { + this.logLevel = logLevel; + return this; + } + + /** + * Get specifies whether to enable reliable logging. Type: boolean (or Expression with resultType boolean). + * + * @return the enableReliableLogging value + */ + public Object enableReliableLogging() { + return this.enableReliableLogging; + } + + /** + * Set specifies whether to enable reliable logging. Type: boolean (or Expression with resultType boolean). + * + * @param enableReliableLogging the enableReliableLogging value to set + * @return the LogStorageSettings object itself. + */ + public LogStorageSettings withEnableReliableLogging(Object enableReliableLogging) { + this.enableReliableLogging = enableReliableLogging; + return this; + } + } diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/MongoDbAtlasCollectionDataset.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/MongoDbAtlasCollectionDataset.java new file mode 100644 index 000000000000..893e80f0fec8 --- /dev/null +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/MongoDbAtlasCollectionDataset.java @@ -0,0 +1,51 @@ +/** + * 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; + +/** + * The MongoDB Atlas database dataset. + */ +@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type", defaultImpl = MongoDbAtlasCollectionDataset.class) +@JsonTypeName("MongoDbAtlasCollection") +@JsonFlatten +public class MongoDbAtlasCollectionDataset extends DatasetInner { + /** + * The collection name of the MongoDB Atlas database. Type: string (or + * Expression with resultType string). + */ + @JsonProperty(value = "typeProperties.collection", required = true) + private Object collection; + + /** + * Get the collection name of the MongoDB Atlas database. Type: string (or Expression with resultType string). + * + * @return the collection value + */ + public Object collection() { + return this.collection; + } + + /** + * Set the collection name of the MongoDB Atlas database. Type: string (or Expression with resultType string). + * + * @param collection the collection value to set + * @return the MongoDbAtlasCollectionDataset object itself. + */ + public MongoDbAtlasCollectionDataset withCollection(Object collection) { + this.collection = collection; + return this; + } + +} diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/MongoDbAtlasLinkedService.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/MongoDbAtlasLinkedService.java new file mode 100644 index 000000000000..3176761e8475 --- /dev/null +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/MongoDbAtlasLinkedService.java @@ -0,0 +1,79 @@ +/** + * 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.LinkedServiceInner; + +/** + * Linked service for MongoDB Atlas data source. + */ +@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type", defaultImpl = MongoDbAtlasLinkedService.class) +@JsonTypeName("MongoDbAtlas") +@JsonFlatten +public class MongoDbAtlasLinkedService extends LinkedServiceInner { + /** + * The MongoDB Atlas connection string. Type: string, SecureString or + * AzureKeyVaultSecretReference. Type: string, SecureString or + * AzureKeyVaultSecretReference. + */ + @JsonProperty(value = "typeProperties.connectionString", required = true) + private Object connectionString; + + /** + * The name of the MongoDB Atlas database that you want to access. Type: + * string (or Expression with resultType string). + */ + @JsonProperty(value = "typeProperties.database", required = true) + private Object database; + + /** + * Get the MongoDB Atlas connection string. Type: string, SecureString or AzureKeyVaultSecretReference. Type: string, SecureString or AzureKeyVaultSecretReference. + * + * @return the connectionString value + */ + public Object connectionString() { + return this.connectionString; + } + + /** + * Set the MongoDB Atlas connection string. Type: string, SecureString or AzureKeyVaultSecretReference. Type: string, SecureString or AzureKeyVaultSecretReference. + * + * @param connectionString the connectionString value to set + * @return the MongoDbAtlasLinkedService object itself. + */ + public MongoDbAtlasLinkedService withConnectionString(Object connectionString) { + this.connectionString = connectionString; + return this; + } + + /** + * Get the name of the MongoDB Atlas database that you want to access. Type: string (or Expression with resultType string). + * + * @return the database value + */ + public Object database() { + return this.database; + } + + /** + * Set the name of the MongoDB Atlas database that you want to access. Type: string (or Expression with resultType string). + * + * @param database the database value to set + * @return the MongoDbAtlasLinkedService object itself. + */ + public MongoDbAtlasLinkedService withDatabase(Object database) { + this.database = database; + return this; + } + +} diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/MongoDbAtlasSource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/MongoDbAtlasSource.java new file mode 100644 index 000000000000..02f8d0964a71 --- /dev/null +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/MongoDbAtlasSource.java @@ -0,0 +1,160 @@ +/** + * 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.List; +import com.fasterxml.jackson.annotation.JsonProperty; +import com.fasterxml.jackson.annotation.JsonTypeInfo; +import com.fasterxml.jackson.annotation.JsonTypeName; + +/** + * A copy activity source for a MongoDB Atlas database. + */ +@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type", defaultImpl = MongoDbAtlasSource.class) +@JsonTypeName("MongoDbAtlasSource") +public class MongoDbAtlasSource extends CopySource { + /** + * Specifies selection filter using query operators. To return all + * documents in a collection, omit this parameter or pass an empty document + * ({}). Type: string (or Expression with resultType string). + */ + @JsonProperty(value = "filter") + private Object filter; + + /** + * Cursor methods for Mongodb query. + */ + @JsonProperty(value = "cursorMethods") + private MongoDbCursorMethodsProperties cursorMethods; + + /** + * Specifies the number of documents to return in each batch of the + * response from MongoDB Atlas instance. In most cases, modifying the batch + * size will not affect the user or the application. This property's main + * purpose is to avoid hit the limitation of response size. Type: integer + * (or Expression with resultType integer). + */ + @JsonProperty(value = "batchSize") + private Object batchSize; + + /** + * Query timeout. Type: string (or Expression with resultType string), + * pattern: ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])). + */ + @JsonProperty(value = "queryTimeout") + private Object queryTimeout; + + /** + * Specifies the additional columns to be added to source data. Type: array + * of objects (or Expression with resultType array of objects). + */ + @JsonProperty(value = "additionalColumns") + private List additionalColumns; + + /** + * Get specifies selection filter using query operators. To return all documents in a collection, omit this parameter or pass an empty document ({}). Type: string (or Expression with resultType string). + * + * @return the filter value + */ + public Object filter() { + return this.filter; + } + + /** + * Set specifies selection filter using query operators. To return all documents in a collection, omit this parameter or pass an empty document ({}). Type: string (or Expression with resultType string). + * + * @param filter the filter value to set + * @return the MongoDbAtlasSource object itself. + */ + public MongoDbAtlasSource withFilter(Object filter) { + this.filter = filter; + return this; + } + + /** + * Get cursor methods for Mongodb query. + * + * @return the cursorMethods value + */ + public MongoDbCursorMethodsProperties cursorMethods() { + return this.cursorMethods; + } + + /** + * Set cursor methods for Mongodb query. + * + * @param cursorMethods the cursorMethods value to set + * @return the MongoDbAtlasSource object itself. + */ + public MongoDbAtlasSource withCursorMethods(MongoDbCursorMethodsProperties cursorMethods) { + this.cursorMethods = cursorMethods; + return this; + } + + /** + * Get specifies the number of documents to return in each batch of the response from MongoDB Atlas instance. In most cases, modifying the batch size will not affect the user or the application. This property's main purpose is to avoid hit the limitation of response size. Type: integer (or Expression with resultType integer). + * + * @return the batchSize value + */ + public Object batchSize() { + return this.batchSize; + } + + /** + * Set specifies the number of documents to return in each batch of the response from MongoDB Atlas instance. In most cases, modifying the batch size will not affect the user or the application. This property's main purpose is to avoid hit the limitation of response size. Type: integer (or Expression with resultType integer). + * + * @param batchSize the batchSize value to set + * @return the MongoDbAtlasSource object itself. + */ + public MongoDbAtlasSource withBatchSize(Object batchSize) { + this.batchSize = batchSize; + return this; + } + + /** + * Get query timeout. Type: string (or Expression with resultType string), pattern: ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])). + * + * @return the queryTimeout value + */ + public Object queryTimeout() { + return this.queryTimeout; + } + + /** + * Set query timeout. Type: string (or Expression with resultType string), pattern: ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])). + * + * @param queryTimeout the queryTimeout value to set + * @return the MongoDbAtlasSource object itself. + */ + public MongoDbAtlasSource withQueryTimeout(Object queryTimeout) { + this.queryTimeout = queryTimeout; + return this; + } + + /** + * Get specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects). + * + * @return the additionalColumns value + */ + public List additionalColumns() { + return this.additionalColumns; + } + + /** + * Set specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects). + * + * @param additionalColumns the additionalColumns value to set + * @return the MongoDbAtlasSource object itself. + */ + public MongoDbAtlasSource withAdditionalColumns(List additionalColumns) { + this.additionalColumns = additionalColumns; + return this; + } + +} diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/OrcCompressionCodec.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/OrcCompressionCodec.java index b8938a88040d..98e1a80f63c8 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/OrcCompressionCodec.java +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/OrcCompressionCodec.java @@ -25,6 +25,9 @@ public final class OrcCompressionCodec extends ExpandableStringEnum