diff --git a/sdk/datafactory/mgmt-v2018_06_01/pom.xml b/sdk/datafactory/mgmt-v2018_06_01/pom.xml
index e74ba7e1edb9a..6a01bee79fc62 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.0
+ 1.1.0
../../../pom.management.xml
azure-mgmt-datafactory
- 1.0.0-beta-1
+ 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/AmazonS3ReadSettings.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AmazonS3ReadSettings.java
index 60113210f030f..484beb3d09351 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AmazonS3ReadSettings.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AmazonS3ReadSettings.java
@@ -60,6 +60,13 @@ public class AmazonS3ReadSettings extends StoreReadSettings {
@JsonProperty(value = "enablePartitionDiscovery")
private Boolean enablePartitionDiscovery;
+ /**
+ * Specify the root path where partition discovery starts from. Type:
+ * string (or Expression with resultType string).
+ */
+ @JsonProperty(value = "partitionRootPath")
+ private Object partitionRootPath;
+
/**
* The start of file's modified datetime. Type: string (or Expression with
* resultType string).
@@ -194,6 +201,26 @@ public AmazonS3ReadSettings withEnablePartitionDiscovery(Boolean enablePartition
return this;
}
+ /**
+ * Get specify the root path where partition discovery starts from. Type: string (or Expression with resultType string).
+ *
+ * @return the partitionRootPath value
+ */
+ public Object partitionRootPath() {
+ return this.partitionRootPath;
+ }
+
+ /**
+ * Set specify the root path where partition discovery starts from. Type: string (or Expression with resultType string).
+ *
+ * @param partitionRootPath the partitionRootPath value to set
+ * @return the AmazonS3ReadSettings object itself.
+ */
+ public AmazonS3ReadSettings withPartitionRootPath(Object partitionRootPath) {
+ this.partitionRootPath = partitionRootPath;
+ return this;
+ }
+
/**
* Get the start of file's modified datetime. Type: string (or Expression with resultType string).
*
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureBlobFSReadSettings.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureBlobFSReadSettings.java
index dc4d0edbdee3b..a8af3156ccdfe 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureBlobFSReadSettings.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureBlobFSReadSettings.java
@@ -53,6 +53,13 @@ public class AzureBlobFSReadSettings extends StoreReadSettings {
@JsonProperty(value = "enablePartitionDiscovery")
private Boolean enablePartitionDiscovery;
+ /**
+ * Specify the root path where partition discovery starts from. Type:
+ * string (or Expression with resultType string).
+ */
+ @JsonProperty(value = "partitionRootPath")
+ private Object partitionRootPath;
+
/**
* The start of file's modified datetime. Type: string (or Expression with
* resultType string).
@@ -167,6 +174,26 @@ public AzureBlobFSReadSettings withEnablePartitionDiscovery(Boolean enablePartit
return this;
}
+ /**
+ * Get specify the root path where partition discovery starts from. Type: string (or Expression with resultType string).
+ *
+ * @return the partitionRootPath value
+ */
+ public Object partitionRootPath() {
+ return this.partitionRootPath;
+ }
+
+ /**
+ * Set specify the root path where partition discovery starts from. Type: string (or Expression with resultType string).
+ *
+ * @param partitionRootPath the partitionRootPath value to set
+ * @return the AzureBlobFSReadSettings object itself.
+ */
+ public AzureBlobFSReadSettings withPartitionRootPath(Object partitionRootPath) {
+ this.partitionRootPath = partitionRootPath;
+ return this;
+ }
+
/**
* Get the start of file's modified datetime. Type: string (or Expression with resultType string).
*
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureBlobStorageReadSettings.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureBlobStorageReadSettings.java
index 7f42a713ccf5e..16bf0a898ee36 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureBlobStorageReadSettings.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureBlobStorageReadSettings.java
@@ -60,6 +60,13 @@ public class AzureBlobStorageReadSettings extends StoreReadSettings {
@JsonProperty(value = "enablePartitionDiscovery")
private Boolean enablePartitionDiscovery;
+ /**
+ * Specify the root path where partition discovery starts from. Type:
+ * string (or Expression with resultType string).
+ */
+ @JsonProperty(value = "partitionRootPath")
+ private Object partitionRootPath;
+
/**
* The start of file's modified datetime. Type: string (or Expression with
* resultType string).
@@ -194,6 +201,26 @@ public AzureBlobStorageReadSettings withEnablePartitionDiscovery(Boolean enableP
return this;
}
+ /**
+ * Get specify the root path where partition discovery starts from. Type: string (or Expression with resultType string).
+ *
+ * @return the partitionRootPath value
+ */
+ public Object partitionRootPath() {
+ return this.partitionRootPath;
+ }
+
+ /**
+ * Set specify the root path where partition discovery starts from. Type: string (or Expression with resultType string).
+ *
+ * @param partitionRootPath the partitionRootPath value to set
+ * @return the AzureBlobStorageReadSettings object itself.
+ */
+ public AzureBlobStorageReadSettings withPartitionRootPath(Object partitionRootPath) {
+ this.partitionRootPath = partitionRootPath;
+ return this;
+ }
+
/**
* Get the start of file's modified datetime. Type: string (or Expression with resultType string).
*
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureDataLakeStoreReadSettings.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureDataLakeStoreReadSettings.java
index 98d24cedeec25..1ebfe36f21b2e 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureDataLakeStoreReadSettings.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureDataLakeStoreReadSettings.java
@@ -53,6 +53,13 @@ public class AzureDataLakeStoreReadSettings extends StoreReadSettings {
@JsonProperty(value = "enablePartitionDiscovery")
private Boolean enablePartitionDiscovery;
+ /**
+ * Specify the root path where partition discovery starts from. Type:
+ * string (or Expression with resultType string).
+ */
+ @JsonProperty(value = "partitionRootPath")
+ private Object partitionRootPath;
+
/**
* The start of file's modified datetime. Type: string (or Expression with
* resultType string).
@@ -167,6 +174,26 @@ public AzureDataLakeStoreReadSettings withEnablePartitionDiscovery(Boolean enabl
return this;
}
+ /**
+ * Get specify the root path where partition discovery starts from. Type: string (or Expression with resultType string).
+ *
+ * @return the partitionRootPath value
+ */
+ public Object partitionRootPath() {
+ return this.partitionRootPath;
+ }
+
+ /**
+ * Set specify the root path where partition discovery starts from. Type: string (or Expression with resultType string).
+ *
+ * @param partitionRootPath the partitionRootPath value to set
+ * @return the AzureDataLakeStoreReadSettings object itself.
+ */
+ public AzureDataLakeStoreReadSettings withPartitionRootPath(Object partitionRootPath) {
+ this.partitionRootPath = partitionRootPath;
+ return this;
+ }
+
/**
* Get the start of file's modified datetime. Type: string (or Expression with resultType string).
*
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureFileStorageLinkedService.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureFileStorageLinkedService.java
index 332f55346613b..71c11abe047fd 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureFileStorageLinkedService.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureFileStorageLinkedService.java
@@ -25,7 +25,7 @@ public class AzureFileStorageLinkedService extends LinkedServiceInner {
* Host name of the server. Type: string (or Expression with resultType
* string).
*/
- @JsonProperty(value = "typeProperties.host", required = true)
+ @JsonProperty(value = "typeProperties.host")
private Object host;
/**
@@ -41,6 +41,41 @@ public class AzureFileStorageLinkedService extends LinkedServiceInner {
@JsonProperty(value = "typeProperties.password")
private SecretBase password;
+ /**
+ * The connection string. It is mutually exclusive with sasUri property.
+ * Type: string, SecureString or AzureKeyVaultSecretReference.
+ */
+ @JsonProperty(value = "typeProperties.connectionString")
+ private Object connectionString;
+
+ /**
+ * The Azure key vault secret reference of accountKey in connection string.
+ */
+ @JsonProperty(value = "typeProperties.accountKey")
+ private AzureKeyVaultSecretReference accountKey;
+
+ /**
+ * SAS URI of the Azure File resource. It is mutually exclusive with
+ * connectionString property. Type: string, SecureString or
+ * AzureKeyVaultSecretReference.
+ */
+ @JsonProperty(value = "typeProperties.sasUri")
+ private Object sasUri;
+
+ /**
+ * The Azure key vault secret reference of sasToken in sas uri.
+ */
+ @JsonProperty(value = "typeProperties.sasToken")
+ private AzureKeyVaultSecretReference sasToken;
+
+ /**
+ * The azure file share name. It is required when auth with
+ * accountKey/sasToken. Type: string (or Expression with resultType
+ * string).
+ */
+ @JsonProperty(value = "typeProperties.fileShare")
+ private Object fileShare;
+
/**
* The encrypted credential used for authentication. Credentials are
* encrypted using the integration runtime credential manager. Type: string
@@ -109,6 +144,106 @@ public AzureFileStorageLinkedService withPassword(SecretBase password) {
return this;
}
+ /**
+ * Get the connection string. It is mutually exclusive with sasUri property. Type: string, SecureString or AzureKeyVaultSecretReference.
+ *
+ * @return the connectionString value
+ */
+ public Object connectionString() {
+ return this.connectionString;
+ }
+
+ /**
+ * Set the connection string. It is mutually exclusive with sasUri property. Type: string, SecureString or AzureKeyVaultSecretReference.
+ *
+ * @param connectionString the connectionString value to set
+ * @return the AzureFileStorageLinkedService object itself.
+ */
+ public AzureFileStorageLinkedService withConnectionString(Object connectionString) {
+ this.connectionString = connectionString;
+ return this;
+ }
+
+ /**
+ * Get the Azure key vault secret reference of accountKey in connection string.
+ *
+ * @return the accountKey value
+ */
+ public AzureKeyVaultSecretReference accountKey() {
+ return this.accountKey;
+ }
+
+ /**
+ * Set the Azure key vault secret reference of accountKey in connection string.
+ *
+ * @param accountKey the accountKey value to set
+ * @return the AzureFileStorageLinkedService object itself.
+ */
+ public AzureFileStorageLinkedService withAccountKey(AzureKeyVaultSecretReference accountKey) {
+ this.accountKey = accountKey;
+ return this;
+ }
+
+ /**
+ * Get sAS URI of the Azure File resource. It is mutually exclusive with connectionString property. Type: string, SecureString or AzureKeyVaultSecretReference.
+ *
+ * @return the sasUri value
+ */
+ public Object sasUri() {
+ return this.sasUri;
+ }
+
+ /**
+ * Set sAS URI of the Azure File resource. It is mutually exclusive with connectionString property. Type: string, SecureString or AzureKeyVaultSecretReference.
+ *
+ * @param sasUri the sasUri value to set
+ * @return the AzureFileStorageLinkedService object itself.
+ */
+ public AzureFileStorageLinkedService withSasUri(Object sasUri) {
+ this.sasUri = sasUri;
+ return this;
+ }
+
+ /**
+ * Get the Azure key vault secret reference of sasToken in sas uri.
+ *
+ * @return the sasToken value
+ */
+ public AzureKeyVaultSecretReference sasToken() {
+ return this.sasToken;
+ }
+
+ /**
+ * Set the Azure key vault secret reference of sasToken in sas uri.
+ *
+ * @param sasToken the sasToken value to set
+ * @return the AzureFileStorageLinkedService object itself.
+ */
+ public AzureFileStorageLinkedService withSasToken(AzureKeyVaultSecretReference sasToken) {
+ this.sasToken = sasToken;
+ return this;
+ }
+
+ /**
+ * Get the azure file share name. It is required when auth with accountKey/sasToken. Type: string (or Expression with resultType string).
+ *
+ * @return the fileShare value
+ */
+ public Object fileShare() {
+ return this.fileShare;
+ }
+
+ /**
+ * Set the azure file share name. It is required when auth with accountKey/sasToken. Type: string (or Expression with resultType string).
+ *
+ * @param fileShare the fileShare value to set
+ * @return the AzureFileStorageLinkedService object itself.
+ */
+ public AzureFileStorageLinkedService withFileShare(Object fileShare) {
+ this.fileShare = fileShare;
+ 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).
*
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureFileStorageReadSettings.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureFileStorageReadSettings.java
index 174897feba009..0ec208be703d5 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureFileStorageReadSettings.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureFileStorageReadSettings.java
@@ -39,6 +39,13 @@ public class AzureFileStorageReadSettings extends StoreReadSettings {
@JsonProperty(value = "wildcardFileName")
private Object wildcardFileName;
+ /**
+ * The prefix filter for the Azure File name starting from root path. Type:
+ * string (or Expression with resultType string).
+ */
+ @JsonProperty(value = "prefix")
+ private Object prefix;
+
/**
* Point to a text file that lists each file (relative path to the path
* configured in the dataset) that you want to copy. Type: string (or
@@ -53,6 +60,13 @@ public class AzureFileStorageReadSettings extends StoreReadSettings {
@JsonProperty(value = "enablePartitionDiscovery")
private Boolean enablePartitionDiscovery;
+ /**
+ * Specify the root path where partition discovery starts from. Type:
+ * string (or Expression with resultType string).
+ */
+ @JsonProperty(value = "partitionRootPath")
+ private Object partitionRootPath;
+
/**
* The start of file's modified datetime. Type: string (or Expression with
* resultType string).
@@ -127,6 +141,26 @@ public AzureFileStorageReadSettings withWildcardFileName(Object wildcardFileName
return this;
}
+ /**
+ * Get the prefix filter for the Azure File name starting from root path. Type: string (or Expression with resultType string).
+ *
+ * @return the prefix value
+ */
+ public Object prefix() {
+ return this.prefix;
+ }
+
+ /**
+ * Set the prefix filter for the Azure File name starting from root path. Type: string (or Expression with resultType string).
+ *
+ * @param prefix the prefix value to set
+ * @return the AzureFileStorageReadSettings object itself.
+ */
+ public AzureFileStorageReadSettings withPrefix(Object prefix) {
+ this.prefix = prefix;
+ return this;
+ }
+
/**
* Get point to a text file that lists each file (relative path to the path configured in the dataset) that you want to copy. Type: string (or Expression with resultType string).
*
@@ -167,6 +201,26 @@ public AzureFileStorageReadSettings withEnablePartitionDiscovery(Boolean enableP
return this;
}
+ /**
+ * Get specify the root path where partition discovery starts from. Type: string (or Expression with resultType string).
+ *
+ * @return the partitionRootPath value
+ */
+ public Object partitionRootPath() {
+ return this.partitionRootPath;
+ }
+
+ /**
+ * Set specify the root path where partition discovery starts from. Type: string (or Expression with resultType string).
+ *
+ * @param partitionRootPath the partitionRootPath value to set
+ * @return the AzureFileStorageReadSettings object itself.
+ */
+ public AzureFileStorageReadSettings withPartitionRootPath(Object partitionRootPath) {
+ this.partitionRootPath = partitionRootPath;
+ return this;
+ }
+
/**
* Get the start of file's modified datetime. Type: string (or Expression with resultType string).
*
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureSqlSource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureSqlSource.java
index 2fd460324466b..d30bb15f8723e 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureSqlSource.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureSqlSource.java
@@ -46,6 +46,20 @@ public class AzureSqlSource extends TabularSource {
@JsonProperty(value = "produceAdditionalTypes")
private Object produceAdditionalTypes;
+ /**
+ * The partition mechanism that will be used for Sql read in parallel.
+ * Possible values include: 'None', 'PhysicalPartitionsOfTable',
+ * 'DynamicRange'.
+ */
+ @JsonProperty(value = "partitionOption")
+ private SqlPartitionOption partitionOption;
+
+ /**
+ * The settings that will be leveraged for Sql source partitioning.
+ */
+ @JsonProperty(value = "partitionSettings")
+ private SqlPartitionSettings partitionSettings;
+
/**
* Get sQL reader query. Type: string (or Expression with resultType string).
*
@@ -126,4 +140,44 @@ public AzureSqlSource withProduceAdditionalTypes(Object produceAdditionalTypes)
return this;
}
+ /**
+ * Get the partition mechanism that will be used for Sql read in parallel. Possible values include: 'None', 'PhysicalPartitionsOfTable', 'DynamicRange'.
+ *
+ * @return the partitionOption value
+ */
+ public SqlPartitionOption partitionOption() {
+ return this.partitionOption;
+ }
+
+ /**
+ * Set the partition mechanism that will be used for Sql read in parallel. Possible values include: 'None', 'PhysicalPartitionsOfTable', 'DynamicRange'.
+ *
+ * @param partitionOption the partitionOption value to set
+ * @return the AzureSqlSource object itself.
+ */
+ public AzureSqlSource withPartitionOption(SqlPartitionOption partitionOption) {
+ this.partitionOption = partitionOption;
+ return this;
+ }
+
+ /**
+ * Get the settings that will be leveraged for Sql source partitioning.
+ *
+ * @return the partitionSettings value
+ */
+ public SqlPartitionSettings partitionSettings() {
+ return this.partitionSettings;
+ }
+
+ /**
+ * Set the settings that will be leveraged for Sql source partitioning.
+ *
+ * @param partitionSettings the partitionSettings value to set
+ * @return the AzureSqlSource object itself.
+ */
+ public AzureSqlSource withPartitionSettings(SqlPartitionSettings partitionSettings) {
+ this.partitionSettings = partitionSettings;
+ return this;
+ }
+
}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/BinaryReadSettings.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/BinaryReadSettings.java
new file mode 100644
index 0000000000000..30457647f33ff
--- /dev/null
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/BinaryReadSettings.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;
+
+/**
+ * Binary read settings.
+ */
+@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type", defaultImpl = BinaryReadSettings.class)
+@JsonTypeName("BinaryReadSettings")
+public class BinaryReadSettings extends FormatReadSettings {
+ /**
+ * Compression settings.
+ */
+ @JsonProperty(value = "compressionProperties")
+ private CompressionReadSettings compressionProperties;
+
+ /**
+ * Get compression settings.
+ *
+ * @return the compressionProperties value
+ */
+ public CompressionReadSettings compressionProperties() {
+ return this.compressionProperties;
+ }
+
+ /**
+ * Set compression settings.
+ *
+ * @param compressionProperties the compressionProperties value to set
+ * @return the BinaryReadSettings object itself.
+ */
+ public BinaryReadSettings withCompressionProperties(CompressionReadSettings compressionProperties) {
+ this.compressionProperties = compressionProperties;
+ return this;
+ }
+
+}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/BinarySource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/BinarySource.java
index 9c7ce23f96ec5..433793d5d4650 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/BinarySource.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/BinarySource.java
@@ -24,6 +24,12 @@ public class BinarySource extends CopySource {
@JsonProperty(value = "storeSettings")
private StoreReadSettings storeSettings;
+ /**
+ * Binary format settings.
+ */
+ @JsonProperty(value = "formatSettings")
+ private BinaryReadSettings formatSettings;
+
/**
* Get binary store settings.
*
@@ -44,4 +50,24 @@ public BinarySource withStoreSettings(StoreReadSettings storeSettings) {
return this;
}
+ /**
+ * Get binary format settings.
+ *
+ * @return the formatSettings value
+ */
+ public BinaryReadSettings formatSettings() {
+ return this.formatSettings;
+ }
+
+ /**
+ * Set binary format settings.
+ *
+ * @param formatSettings the formatSettings value to set
+ * @return the BinarySource object itself.
+ */
+ public BinarySource withFormatSettings(BinaryReadSettings formatSettings) {
+ this.formatSettings = formatSettings;
+ 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
new file mode 100644
index 0000000000000..0ccdda9e73593
--- /dev/null
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CompressionReadSettings.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;
+
+/**
+ * Compression read settings.
+ */
+@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type", defaultImpl = CompressionReadSettings.class)
+@JsonTypeName("CompressionReadSettings")
+@JsonSubTypes({
+ @JsonSubTypes.Type(name = "ZipDeflateReadSettings", value = ZipDeflateReadSettings.class)
+})
+public class CompressionReadSettings {
+ /**
+ * 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 CompressionReadSettings object itself.
+ */
+ public CompressionReadSettings 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/CopySink.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CopySink.java
index 785bf65edbdb3..dc770c33e5882 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
@@ -34,6 +34,7 @@
@JsonSubTypes.Type(name = "AzureBlobFSSink", value = AzureBlobFSSink.class),
@JsonSubTypes.Type(name = "AzureDataLakeStoreSink", value = AzureDataLakeStoreSink.class),
@JsonSubTypes.Type(name = "OracleSink", value = OracleSink.class),
+ @JsonSubTypes.Type(name = "SnowflakeSink", value = SnowflakeSink.class),
@JsonSubTypes.Type(name = "SqlDWSink", value = SqlDWSink.class),
@JsonSubTypes.Type(name = "SqlMISink", value = SqlMISink.class),
@JsonSubTypes.Type(name = "AzureSqlSink", value = AzureSqlSink.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 90691b2f7239e..78a33ff502840 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
@@ -20,6 +20,8 @@
@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type", defaultImpl = CopySource.class)
@JsonTypeName("CopySource")
@JsonSubTypes({
+ @JsonSubTypes.Type(name = "SharePointOnlineListSource", value = SharePointOnlineListSource.class),
+ @JsonSubTypes.Type(name = "SnowflakeSource", value = SnowflakeSource.class),
@JsonSubTypes.Type(name = "HttpSource", value = HttpSource.class),
@JsonSubTypes.Type(name = "AzureBlobFSSource", value = AzureBlobFSSource.class),
@JsonSubTypes.Type(name = "AzureDataLakeStoreSource", value = AzureDataLakeStoreSource.class),
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DelimitedTextReadSettings.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DelimitedTextReadSettings.java
index 1868d9076aba1..9f8ef1a8777be 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DelimitedTextReadSettings.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DelimitedTextReadSettings.java
@@ -25,6 +25,12 @@ public class DelimitedTextReadSettings extends FormatReadSettings {
@JsonProperty(value = "skipLineCount")
private Object skipLineCount;
+ /**
+ * Compression settings.
+ */
+ @JsonProperty(value = "compressionProperties")
+ private CompressionReadSettings compressionProperties;
+
/**
* Get indicates the number of non-empty rows to skip when reading data from input files. Type: integer (or Expression with resultType integer).
*
@@ -45,4 +51,24 @@ public DelimitedTextReadSettings withSkipLineCount(Object skipLineCount) {
return this;
}
+ /**
+ * Get compression settings.
+ *
+ * @return the compressionProperties value
+ */
+ public CompressionReadSettings compressionProperties() {
+ return this.compressionProperties;
+ }
+
+ /**
+ * Set compression settings.
+ *
+ * @param compressionProperties the compressionProperties value to set
+ * @return the DelimitedTextReadSettings object itself.
+ */
+ public DelimitedTextReadSettings withCompressionProperties(CompressionReadSettings compressionProperties) {
+ this.compressionProperties = compressionProperties;
+ return this;
+ }
+
}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DynamicsAXSource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DynamicsAXSource.java
index 78474ef80debc..fc2edb22f8339 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DynamicsAXSource.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DynamicsAXSource.java
@@ -25,6 +25,15 @@ public class DynamicsAXSource extends TabularSource {
@JsonProperty(value = "query")
private Object query;
+ /**
+ * The timeout (TimeSpan) to get an HTTP response. It is the timeout to get
+ * a response, not the timeout to read response data. Default value:
+ * 00:05:00. Type: string (or Expression with resultType string), pattern:
+ * ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ */
+ @JsonProperty(value = "httpRequestTimeout")
+ private Object httpRequestTimeout;
+
/**
* Get a query to retrieve data from source. Type: string (or Expression with resultType string).
*
@@ -45,4 +54,24 @@ public DynamicsAXSource withQuery(Object query) {
return this;
}
+ /**
+ * Get the timeout (TimeSpan) to get an HTTP response. It is the timeout to get a response, not the timeout to read response data. Default value: 00:05:00. Type: string (or Expression with resultType string), pattern: ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ *
+ * @return the httpRequestTimeout value
+ */
+ public Object httpRequestTimeout() {
+ return this.httpRequestTimeout;
+ }
+
+ /**
+ * Set the timeout (TimeSpan) to get an HTTP response. It is the timeout to get a response, not the timeout to read response data. Default value: 00:05:00. Type: string (or Expression with resultType string), pattern: ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ *
+ * @param httpRequestTimeout the httpRequestTimeout value to set
+ * @return the DynamicsAXSource object itself.
+ */
+ public DynamicsAXSource withHttpRequestTimeout(Object httpRequestTimeout) {
+ this.httpRequestTimeout = httpRequestTimeout;
+ return this;
+ }
+
}
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
new file mode 100644
index 0000000000000..6f322b480f3fa
--- /dev/null
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/ExportSettings.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;
+
+/**
+ * Export command settings.
+ */
+@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type", defaultImpl = ExportSettings.class)
+@JsonTypeName("ExportSettings")
+@JsonSubTypes({
+ @JsonSubTypes.Type(name = "SnowflakeExportCopyCommand", value = SnowflakeExportCopyCommand.class)
+})
+public class ExportSettings {
+ /**
+ * 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 ExportSettings object itself.
+ */
+ public ExportSettings 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/FileServerReadSettings.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/FileServerReadSettings.java
index 9a64b8e218929..8946528386f81 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/FileServerReadSettings.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/FileServerReadSettings.java
@@ -53,6 +53,13 @@ public class FileServerReadSettings extends StoreReadSettings {
@JsonProperty(value = "enablePartitionDiscovery")
private Boolean enablePartitionDiscovery;
+ /**
+ * Specify the root path where partition discovery starts from. Type:
+ * string (or Expression with resultType string).
+ */
+ @JsonProperty(value = "partitionRootPath")
+ private Object partitionRootPath;
+
/**
* The start of file's modified datetime. Type: string (or Expression with
* resultType string).
@@ -67,6 +74,14 @@ public class FileServerReadSettings extends StoreReadSettings {
@JsonProperty(value = "modifiedDatetimeEnd")
private Object modifiedDatetimeEnd;
+ /**
+ * Specify a filter to be used to select a subset of files in the
+ * folderPath rather than all files. Type: string (or Expression with
+ * resultType string).
+ */
+ @JsonProperty(value = "fileFilter")
+ private Object fileFilter;
+
/**
* Get if true, files under the folder path will be read recursively. Default is true. Type: boolean (or Expression with resultType boolean).
*
@@ -167,6 +182,26 @@ public FileServerReadSettings withEnablePartitionDiscovery(Boolean enablePartiti
return this;
}
+ /**
+ * Get specify the root path where partition discovery starts from. Type: string (or Expression with resultType string).
+ *
+ * @return the partitionRootPath value
+ */
+ public Object partitionRootPath() {
+ return this.partitionRootPath;
+ }
+
+ /**
+ * Set specify the root path where partition discovery starts from. Type: string (or Expression with resultType string).
+ *
+ * @param partitionRootPath the partitionRootPath value to set
+ * @return the FileServerReadSettings object itself.
+ */
+ public FileServerReadSettings withPartitionRootPath(Object partitionRootPath) {
+ this.partitionRootPath = partitionRootPath;
+ return this;
+ }
+
/**
* Get the start of file's modified datetime. Type: string (or Expression with resultType string).
*
@@ -207,4 +242,24 @@ public FileServerReadSettings withModifiedDatetimeEnd(Object modifiedDatetimeEnd
return this;
}
+ /**
+ * Get specify a filter to be used to select a subset of files in the folderPath rather than all files. Type: string (or Expression with resultType string).
+ *
+ * @return the fileFilter value
+ */
+ public Object fileFilter() {
+ return this.fileFilter;
+ }
+
+ /**
+ * Set specify a filter to be used to select a subset of files in the folderPath rather than all files. Type: string (or Expression with resultType string).
+ *
+ * @param fileFilter the fileFilter value to set
+ * @return the FileServerReadSettings object itself.
+ */
+ public FileServerReadSettings withFileFilter(Object fileFilter) {
+ this.fileFilter = fileFilter;
+ return this;
+ }
+
}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/FormatReadSettings.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/FormatReadSettings.java
index eef505e9b6214..941661c93983d 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/FormatReadSettings.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/FormatReadSettings.java
@@ -20,7 +20,9 @@
@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type", defaultImpl = FormatReadSettings.class)
@JsonTypeName("FormatReadSettings")
@JsonSubTypes({
- @JsonSubTypes.Type(name = "DelimitedTextReadSettings", value = DelimitedTextReadSettings.class)
+ @JsonSubTypes.Type(name = "JsonReadSettings", value = JsonReadSettings.class),
+ @JsonSubTypes.Type(name = "DelimitedTextReadSettings", value = DelimitedTextReadSettings.class),
+ @JsonSubTypes.Type(name = "BinaryReadSettings", value = BinaryReadSettings.class)
})
public class FormatReadSettings {
/**
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/FtpReadSettings.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/FtpReadSettings.java
index 921642f9ff353..bf9383ce9e1f3 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/FtpReadSettings.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/FtpReadSettings.java
@@ -39,6 +39,19 @@ public class FtpReadSettings extends StoreReadSettings {
@JsonProperty(value = "wildcardFileName")
private Object wildcardFileName;
+ /**
+ * Indicates whether to enable partition discovery.
+ */
+ @JsonProperty(value = "enablePartitionDiscovery")
+ private Boolean enablePartitionDiscovery;
+
+ /**
+ * Specify the root path where partition discovery starts from. Type:
+ * string (or Expression with resultType string).
+ */
+ @JsonProperty(value = "partitionRootPath")
+ private Object partitionRootPath;
+
/**
* Point to a text file that lists each file (relative path to the path
* configured in the dataset) that you want to copy. Type: string (or
@@ -113,6 +126,46 @@ public FtpReadSettings withWildcardFileName(Object wildcardFileName) {
return this;
}
+ /**
+ * Get indicates whether to enable partition discovery.
+ *
+ * @return the enablePartitionDiscovery value
+ */
+ public Boolean enablePartitionDiscovery() {
+ return this.enablePartitionDiscovery;
+ }
+
+ /**
+ * Set indicates whether to enable partition discovery.
+ *
+ * @param enablePartitionDiscovery the enablePartitionDiscovery value to set
+ * @return the FtpReadSettings object itself.
+ */
+ public FtpReadSettings withEnablePartitionDiscovery(Boolean enablePartitionDiscovery) {
+ this.enablePartitionDiscovery = enablePartitionDiscovery;
+ return this;
+ }
+
+ /**
+ * Get specify the root path where partition discovery starts from. Type: string (or Expression with resultType string).
+ *
+ * @return the partitionRootPath value
+ */
+ public Object partitionRootPath() {
+ return this.partitionRootPath;
+ }
+
+ /**
+ * Set specify the root path where partition discovery starts from. Type: string (or Expression with resultType string).
+ *
+ * @param partitionRootPath the partitionRootPath value to set
+ * @return the FtpReadSettings object itself.
+ */
+ public FtpReadSettings withPartitionRootPath(Object partitionRootPath) {
+ this.partitionRootPath = partitionRootPath;
+ return this;
+ }
+
/**
* Get point to a text file that lists each file (relative path to the path configured in the dataset) that you want to copy. Type: string (or Expression with resultType string).
*
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/GoogleCloudStorageReadSettings.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/GoogleCloudStorageReadSettings.java
index c6368a06345f3..dd1435268df6d 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/GoogleCloudStorageReadSettings.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/GoogleCloudStorageReadSettings.java
@@ -60,6 +60,13 @@ public class GoogleCloudStorageReadSettings extends StoreReadSettings {
@JsonProperty(value = "enablePartitionDiscovery")
private Boolean enablePartitionDiscovery;
+ /**
+ * Specify the root path where partition discovery starts from. Type:
+ * string (or Expression with resultType string).
+ */
+ @JsonProperty(value = "partitionRootPath")
+ private Object partitionRootPath;
+
/**
* The start of file's modified datetime. Type: string (or Expression with
* resultType string).
@@ -194,6 +201,26 @@ public GoogleCloudStorageReadSettings withEnablePartitionDiscovery(Boolean enabl
return this;
}
+ /**
+ * Get specify the root path where partition discovery starts from. Type: string (or Expression with resultType string).
+ *
+ * @return the partitionRootPath value
+ */
+ public Object partitionRootPath() {
+ return this.partitionRootPath;
+ }
+
+ /**
+ * Set specify the root path where partition discovery starts from. Type: string (or Expression with resultType string).
+ *
+ * @param partitionRootPath the partitionRootPath value to set
+ * @return the GoogleCloudStorageReadSettings object itself.
+ */
+ public GoogleCloudStorageReadSettings withPartitionRootPath(Object partitionRootPath) {
+ this.partitionRootPath = partitionRootPath;
+ return this;
+ }
+
/**
* Get the start of file's modified datetime. Type: string (or Expression with resultType string).
*
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/HdfsReadSettings.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/HdfsReadSettings.java
index 6915c721c2da3..f6939ccc73c1a 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/HdfsReadSettings.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/HdfsReadSettings.java
@@ -53,6 +53,13 @@ public class HdfsReadSettings extends StoreReadSettings {
@JsonProperty(value = "enablePartitionDiscovery")
private Boolean enablePartitionDiscovery;
+ /**
+ * Specify the root path where partition discovery starts from. Type:
+ * string (or Expression with resultType string).
+ */
+ @JsonProperty(value = "partitionRootPath")
+ private Object partitionRootPath;
+
/**
* The start of file's modified datetime. Type: string (or Expression with
* resultType string).
@@ -173,6 +180,26 @@ public HdfsReadSettings withEnablePartitionDiscovery(Boolean enablePartitionDisc
return this;
}
+ /**
+ * Get specify the root path where partition discovery starts from. Type: string (or Expression with resultType string).
+ *
+ * @return the partitionRootPath value
+ */
+ public Object partitionRootPath() {
+ return this.partitionRootPath;
+ }
+
+ /**
+ * Set specify the root path where partition discovery starts from. Type: string (or Expression with resultType string).
+ *
+ * @param partitionRootPath the partitionRootPath value to set
+ * @return the HdfsReadSettings object itself.
+ */
+ public HdfsReadSettings withPartitionRootPath(Object partitionRootPath) {
+ this.partitionRootPath = partitionRootPath;
+ return this;
+ }
+
/**
* Get the start of file's modified datetime. Type: string (or Expression with resultType string).
*
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/HttpReadSettings.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/HttpReadSettings.java
index 1c08927d4fd25..be25e6fb02c7e 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/HttpReadSettings.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/HttpReadSettings.java
@@ -46,6 +46,19 @@ public class HttpReadSettings extends StoreReadSettings {
@JsonProperty(value = "requestTimeout")
private Object requestTimeout;
+ /**
+ * Indicates whether to enable partition discovery.
+ */
+ @JsonProperty(value = "enablePartitionDiscovery")
+ private Boolean enablePartitionDiscovery;
+
+ /**
+ * Specify the root path where partition discovery starts from. Type:
+ * string (or Expression with resultType string).
+ */
+ @JsonProperty(value = "partitionRootPath")
+ private Object partitionRootPath;
+
/**
* Get the HTTP method used to call the RESTful API. The default is GET. Type: string (or Expression with resultType string).
*
@@ -126,4 +139,44 @@ public HttpReadSettings withRequestTimeout(Object requestTimeout) {
return this;
}
+ /**
+ * Get indicates whether to enable partition discovery.
+ *
+ * @return the enablePartitionDiscovery value
+ */
+ public Boolean enablePartitionDiscovery() {
+ return this.enablePartitionDiscovery;
+ }
+
+ /**
+ * Set indicates whether to enable partition discovery.
+ *
+ * @param enablePartitionDiscovery the enablePartitionDiscovery value to set
+ * @return the HttpReadSettings object itself.
+ */
+ public HttpReadSettings withEnablePartitionDiscovery(Boolean enablePartitionDiscovery) {
+ this.enablePartitionDiscovery = enablePartitionDiscovery;
+ return this;
+ }
+
+ /**
+ * Get specify the root path where partition discovery starts from. Type: string (or Expression with resultType string).
+ *
+ * @return the partitionRootPath value
+ */
+ public Object partitionRootPath() {
+ return this.partitionRootPath;
+ }
+
+ /**
+ * Set specify the root path where partition discovery starts from. Type: string (or Expression with resultType string).
+ *
+ * @param partitionRootPath the partitionRootPath value to set
+ * @return the HttpReadSettings object itself.
+ */
+ public HttpReadSettings withPartitionRootPath(Object partitionRootPath) {
+ this.partitionRootPath = partitionRootPath;
+ return this;
+ }
+
}
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
new file mode 100644
index 0000000000000..a6ce0f6222051
--- /dev/null
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/ImportSettings.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;
+
+/**
+ * Import command settings.
+ */
+@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type", defaultImpl = ImportSettings.class)
+@JsonTypeName("ImportSettings")
+@JsonSubTypes({
+ @JsonSubTypes.Type(name = "SnowflakeImportCopyCommand", value = SnowflakeImportCopyCommand.class)
+})
+public class ImportSettings {
+ /**
+ * 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 ImportSettings object itself.
+ */
+ public ImportSettings 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/IntegrationRuntimeSsisProperties.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/IntegrationRuntimeSsisProperties.java
index 9724b925ec960..cf10170a64179 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/IntegrationRuntimeSsisProperties.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/IntegrationRuntimeSsisProperties.java
@@ -61,6 +61,12 @@ public class IntegrationRuntimeSsisProperties {
@JsonProperty(value = "expressCustomSetupProperties")
private List expressCustomSetupProperties;
+ /**
+ * Package stores for the SSIS Integration Runtime.
+ */
+ @JsonProperty(value = "packageStores")
+ private List packageStores;
+
/**
* Get unmatched properties from the message are deserialized this collection.
*
@@ -201,4 +207,24 @@ public IntegrationRuntimeSsisProperties withExpressCustomSetupProperties(List packageStores() {
+ return this.packageStores;
+ }
+
+ /**
+ * Set package stores for the SSIS Integration Runtime.
+ *
+ * @param packageStores the packageStores value to set
+ * @return the IntegrationRuntimeSsisProperties object itself.
+ */
+ public IntegrationRuntimeSsisProperties withPackageStores(List packageStores) {
+ this.packageStores = packageStores;
+ return this;
+ }
+
}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/JsonReadSettings.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/JsonReadSettings.java
new file mode 100644
index 0000000000000..751f29fc8b4a9
--- /dev/null
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/JsonReadSettings.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;
+
+/**
+ * Json read settings.
+ */
+@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type", defaultImpl = JsonReadSettings.class)
+@JsonTypeName("JsonReadSettings")
+public class JsonReadSettings extends FormatReadSettings {
+ /**
+ * Compression settings.
+ */
+ @JsonProperty(value = "compressionProperties")
+ private CompressionReadSettings compressionProperties;
+
+ /**
+ * Get compression settings.
+ *
+ * @return the compressionProperties value
+ */
+ public CompressionReadSettings compressionProperties() {
+ return this.compressionProperties;
+ }
+
+ /**
+ * Set compression settings.
+ *
+ * @param compressionProperties the compressionProperties value to set
+ * @return the JsonReadSettings object itself.
+ */
+ public JsonReadSettings withCompressionProperties(CompressionReadSettings compressionProperties) {
+ this.compressionProperties = compressionProperties;
+ return this;
+ }
+
+}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/JsonSource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/JsonSource.java
index 84a3eb79a72f1..38cfa928a3cde 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/JsonSource.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/JsonSource.java
@@ -25,6 +25,12 @@ public class JsonSource extends CopySource {
@JsonProperty(value = "storeSettings")
private StoreReadSettings storeSettings;
+ /**
+ * Json format settings.
+ */
+ @JsonProperty(value = "formatSettings")
+ private JsonReadSettings formatSettings;
+
/**
* Specifies the additional columns to be added to source data. Type: array
* of objects (or Expression with resultType array of objects).
@@ -52,6 +58,26 @@ public JsonSource withStoreSettings(StoreReadSettings storeSettings) {
return this;
}
+ /**
+ * Get json format settings.
+ *
+ * @return the formatSettings value
+ */
+ public JsonReadSettings formatSettings() {
+ return this.formatSettings;
+ }
+
+ /**
+ * Set json format settings.
+ *
+ * @param formatSettings the formatSettings value to set
+ * @return the JsonSource object itself.
+ */
+ public JsonSource withFormatSettings(JsonReadSettings formatSettings) {
+ this.formatSettings = formatSettings;
+ return this;
+ }
+
/**
* Get specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
*
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/ODataSource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/ODataSource.java
index 57c3fae095737..01b9c8e5b9f53 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/ODataSource.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/ODataSource.java
@@ -26,6 +26,15 @@ public class ODataSource extends CopySource {
@JsonProperty(value = "query")
private Object query;
+ /**
+ * The timeout (TimeSpan) to get an HTTP response. It is the timeout to get
+ * a response, not the timeout to read response data. Default value:
+ * 00:05:00. Type: string (or Expression with resultType string), pattern:
+ * ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ */
+ @JsonProperty(value = "httpRequestTimeout")
+ private Object httpRequestTimeout;
+
/**
* Specifies the additional columns to be added to source data. Type: array
* of objects (or Expression with resultType array of objects).
@@ -53,6 +62,26 @@ public ODataSource withQuery(Object query) {
return this;
}
+ /**
+ * Get the timeout (TimeSpan) to get an HTTP response. It is the timeout to get a response, not the timeout to read response data. Default value: 00:05:00. Type: string (or Expression with resultType string), pattern: ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ *
+ * @return the httpRequestTimeout value
+ */
+ public Object httpRequestTimeout() {
+ return this.httpRequestTimeout;
+ }
+
+ /**
+ * Set the timeout (TimeSpan) to get an HTTP response. It is the timeout to get a response, not the timeout to read response data. Default value: 00:05:00. Type: string (or Expression with resultType string), pattern: ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ *
+ * @param httpRequestTimeout the httpRequestTimeout value to set
+ * @return the ODataSource object itself.
+ */
+ public ODataSource withHttpRequestTimeout(Object httpRequestTimeout) {
+ this.httpRequestTimeout = httpRequestTimeout;
+ return this;
+ }
+
/**
* Get specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
*
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/PackageStore.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/PackageStore.java
new file mode 100644
index 0000000000000..08655b7752db0
--- /dev/null
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/PackageStore.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;
+
+/**
+ * Package store for the SSIS integration runtime.
+ */
+public class PackageStore {
+ /**
+ * The name of the package store.
+ */
+ @JsonProperty(value = "name", required = true)
+ private String name;
+
+ /**
+ * The package store linked service reference.
+ */
+ @JsonProperty(value = "packageStoreLinkedService", required = true)
+ private EntityReference packageStoreLinkedService;
+
+ /**
+ * Get the name of the package store.
+ *
+ * @return the name value
+ */
+ public String name() {
+ return this.name;
+ }
+
+ /**
+ * Set the name of the package store.
+ *
+ * @param name the name value to set
+ * @return the PackageStore object itself.
+ */
+ public PackageStore withName(String name) {
+ this.name = name;
+ return this;
+ }
+
+ /**
+ * Get the package store linked service reference.
+ *
+ * @return the packageStoreLinkedService value
+ */
+ public EntityReference packageStoreLinkedService() {
+ return this.packageStoreLinkedService;
+ }
+
+ /**
+ * Set the package store linked service reference.
+ *
+ * @param packageStoreLinkedService the packageStoreLinkedService value to set
+ * @return the PackageStore object itself.
+ */
+ public PackageStore withPackageStoreLinkedService(EntityReference packageStoreLinkedService) {
+ this.packageStoreLinkedService = packageStoreLinkedService;
+ return this;
+ }
+
+}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SSISPackageLocation.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SSISPackageLocation.java
index b41049152c878..06ba20b800f0b 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SSISPackageLocation.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SSISPackageLocation.java
@@ -26,7 +26,7 @@ public class SSISPackageLocation {
/**
* The type of SSIS package location. Possible values include: 'SSISDB',
- * 'File', 'InlinePackage'.
+ * 'File', 'InlinePackage', 'PackageStore'.
*/
@JsonProperty(value = "type")
private SsisPackageLocationType type;
@@ -50,6 +50,12 @@ public class SSISPackageLocation {
@JsonProperty(value = "typeProperties.configurationPath")
private Object configurationPath;
+ /**
+ * The configuration file access credential.
+ */
+ @JsonProperty(value = "typeProperties.configurationAccessCredential")
+ private SSISAccessCredential configurationAccessCredential;
+
/**
* The package name.
*/
@@ -96,7 +102,7 @@ public SSISPackageLocation withPackagePath(Object packagePath) {
}
/**
- * Get the type of SSIS package location. Possible values include: 'SSISDB', 'File', 'InlinePackage'.
+ * Get the type of SSIS package location. Possible values include: 'SSISDB', 'File', 'InlinePackage', 'PackageStore'.
*
* @return the type value
*/
@@ -105,7 +111,7 @@ public SsisPackageLocationType type() {
}
/**
- * Set the type of SSIS package location. Possible values include: 'SSISDB', 'File', 'InlinePackage'.
+ * Set the type of SSIS package location. Possible values include: 'SSISDB', 'File', 'InlinePackage', 'PackageStore'.
*
* @param type the type value to set
* @return the SSISPackageLocation object itself.
@@ -175,6 +181,26 @@ public SSISPackageLocation withConfigurationPath(Object configurationPath) {
return this;
}
+ /**
+ * Get the configuration file access credential.
+ *
+ * @return the configurationAccessCredential value
+ */
+ public SSISAccessCredential configurationAccessCredential() {
+ return this.configurationAccessCredential;
+ }
+
+ /**
+ * Set the configuration file access credential.
+ *
+ * @param configurationAccessCredential the configurationAccessCredential value to set
+ * @return the SSISPackageLocation object itself.
+ */
+ public SSISPackageLocation withConfigurationAccessCredential(SSISAccessCredential configurationAccessCredential) {
+ this.configurationAccessCredential = configurationAccessCredential;
+ return this;
+ }
+
/**
* Get the package name.
*
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SapCloudForCustomerSink.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SapCloudForCustomerSink.java
index 9e21ed6d3babe..0874e25636103 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SapCloudForCustomerSink.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SapCloudForCustomerSink.java
@@ -25,6 +25,15 @@ public class SapCloudForCustomerSink extends CopySink {
@JsonProperty(value = "writeBehavior")
private SapCloudForCustomerSinkWriteBehavior writeBehavior;
+ /**
+ * The timeout (TimeSpan) to get an HTTP response. It is the timeout to get
+ * a response, not the timeout to read response data. Default value:
+ * 00:05:00. Type: string (or Expression with resultType string), pattern:
+ * ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ */
+ @JsonProperty(value = "httpRequestTimeout")
+ private Object httpRequestTimeout;
+
/**
* Get the write behavior for the operation. Default is 'Insert'. Possible values include: 'Insert', 'Update'.
*
@@ -45,4 +54,24 @@ public SapCloudForCustomerSink withWriteBehavior(SapCloudForCustomerSinkWriteBeh
return this;
}
+ /**
+ * Get the timeout (TimeSpan) to get an HTTP response. It is the timeout to get a response, not the timeout to read response data. Default value: 00:05:00. Type: string (or Expression with resultType string), pattern: ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ *
+ * @return the httpRequestTimeout value
+ */
+ public Object httpRequestTimeout() {
+ return this.httpRequestTimeout;
+ }
+
+ /**
+ * Set the timeout (TimeSpan) to get an HTTP response. It is the timeout to get a response, not the timeout to read response data. Default value: 00:05:00. Type: string (or Expression with resultType string), pattern: ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ *
+ * @param httpRequestTimeout the httpRequestTimeout value to set
+ * @return the SapCloudForCustomerSink object itself.
+ */
+ public SapCloudForCustomerSink withHttpRequestTimeout(Object httpRequestTimeout) {
+ this.httpRequestTimeout = httpRequestTimeout;
+ return this;
+ }
+
}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SapCloudForCustomerSource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SapCloudForCustomerSource.java
index ceed077c4ed48..165c389781f98 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SapCloudForCustomerSource.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SapCloudForCustomerSource.java
@@ -25,6 +25,15 @@ public class SapCloudForCustomerSource extends TabularSource {
@JsonProperty(value = "query")
private Object query;
+ /**
+ * The timeout (TimeSpan) to get an HTTP response. It is the timeout to get
+ * a response, not the timeout to read response data. Default value:
+ * 00:05:00. Type: string (or Expression with resultType string), pattern:
+ * ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ */
+ @JsonProperty(value = "httpRequestTimeout")
+ private Object httpRequestTimeout;
+
/**
* Get sAP Cloud for Customer OData query. For example, "$top=1". Type: string (or Expression with resultType string).
*
@@ -45,4 +54,24 @@ public SapCloudForCustomerSource withQuery(Object query) {
return this;
}
+ /**
+ * Get the timeout (TimeSpan) to get an HTTP response. It is the timeout to get a response, not the timeout to read response data. Default value: 00:05:00. Type: string (or Expression with resultType string), pattern: ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ *
+ * @return the httpRequestTimeout value
+ */
+ public Object httpRequestTimeout() {
+ return this.httpRequestTimeout;
+ }
+
+ /**
+ * Set the timeout (TimeSpan) to get an HTTP response. It is the timeout to get a response, not the timeout to read response data. Default value: 00:05:00. Type: string (or Expression with resultType string), pattern: ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ *
+ * @param httpRequestTimeout the httpRequestTimeout value to set
+ * @return the SapCloudForCustomerSource object itself.
+ */
+ public SapCloudForCustomerSource withHttpRequestTimeout(Object httpRequestTimeout) {
+ this.httpRequestTimeout = httpRequestTimeout;
+ return this;
+ }
+
}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SapEccSource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SapEccSource.java
index fc07525a791c6..a2fdf152404da 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SapEccSource.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SapEccSource.java
@@ -25,6 +25,15 @@ public class SapEccSource extends TabularSource {
@JsonProperty(value = "query")
private Object query;
+ /**
+ * The timeout (TimeSpan) to get an HTTP response. It is the timeout to get
+ * a response, not the timeout to read response data. Default value:
+ * 00:05:00. Type: string (or Expression with resultType string), pattern:
+ * ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ */
+ @JsonProperty(value = "httpRequestTimeout")
+ private Object httpRequestTimeout;
+
/**
* Get sAP ECC OData query. For example, "$top=1". Type: string (or Expression with resultType string).
*
@@ -45,4 +54,24 @@ public SapEccSource withQuery(Object query) {
return this;
}
+ /**
+ * Get the timeout (TimeSpan) to get an HTTP response. It is the timeout to get a response, not the timeout to read response data. Default value: 00:05:00. Type: string (or Expression with resultType string), pattern: ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ *
+ * @return the httpRequestTimeout value
+ */
+ public Object httpRequestTimeout() {
+ return this.httpRequestTimeout;
+ }
+
+ /**
+ * Set the timeout (TimeSpan) to get an HTTP response. It is the timeout to get a response, not the timeout to read response data. Default value: 00:05:00. Type: string (or Expression with resultType string), pattern: ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ *
+ * @param httpRequestTimeout the httpRequestTimeout value to set
+ * @return the SapEccSource object itself.
+ */
+ public SapEccSource withHttpRequestTimeout(Object httpRequestTimeout) {
+ this.httpRequestTimeout = httpRequestTimeout;
+ return this;
+ }
+
}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SapHanaLinkedService.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SapHanaLinkedService.java
index 5a943f3b4d5a3..a998c492824a6 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SapHanaLinkedService.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SapHanaLinkedService.java
@@ -32,7 +32,7 @@ public class SapHanaLinkedService extends LinkedServiceInner {
* Host name of the SAP HANA server. Type: string (or Expression with
* resultType string).
*/
- @JsonProperty(value = "typeProperties.server", required = true)
+ @JsonProperty(value = "typeProperties.server")
private Object server;
/**
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SftpReadSettings.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SftpReadSettings.java
index c8e3012479407..8f5acc2bfab50 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SftpReadSettings.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SftpReadSettings.java
@@ -39,6 +39,19 @@ public class SftpReadSettings extends StoreReadSettings {
@JsonProperty(value = "wildcardFileName")
private Object wildcardFileName;
+ /**
+ * Indicates whether to enable partition discovery.
+ */
+ @JsonProperty(value = "enablePartitionDiscovery")
+ private Boolean enablePartitionDiscovery;
+
+ /**
+ * Specify the root path where partition discovery starts from. Type:
+ * string (or Expression with resultType string).
+ */
+ @JsonProperty(value = "partitionRootPath")
+ private Object partitionRootPath;
+
/**
* Point to a text file that lists each file (relative path to the path
* configured in the dataset) that you want to copy. Type: string (or
@@ -121,6 +134,46 @@ public SftpReadSettings withWildcardFileName(Object wildcardFileName) {
return this;
}
+ /**
+ * Get indicates whether to enable partition discovery.
+ *
+ * @return the enablePartitionDiscovery value
+ */
+ public Boolean enablePartitionDiscovery() {
+ return this.enablePartitionDiscovery;
+ }
+
+ /**
+ * Set indicates whether to enable partition discovery.
+ *
+ * @param enablePartitionDiscovery the enablePartitionDiscovery value to set
+ * @return the SftpReadSettings object itself.
+ */
+ public SftpReadSettings withEnablePartitionDiscovery(Boolean enablePartitionDiscovery) {
+ this.enablePartitionDiscovery = enablePartitionDiscovery;
+ return this;
+ }
+
+ /**
+ * Get specify the root path where partition discovery starts from. Type: string (or Expression with resultType string).
+ *
+ * @return the partitionRootPath value
+ */
+ public Object partitionRootPath() {
+ return this.partitionRootPath;
+ }
+
+ /**
+ * Set specify the root path where partition discovery starts from. Type: string (or Expression with resultType string).
+ *
+ * @param partitionRootPath the partitionRootPath value to set
+ * @return the SftpReadSettings object itself.
+ */
+ public SftpReadSettings withPartitionRootPath(Object partitionRootPath) {
+ this.partitionRootPath = partitionRootPath;
+ return this;
+ }
+
/**
* Get point to a text file that lists each file (relative path to the path configured in the dataset) that you want to copy. Type: string (or Expression with resultType string).
*
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SharePointOnlineListLinkedService.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SharePointOnlineListLinkedService.java
new file mode 100644
index 0000000000000..deb308ebde01b
--- /dev/null
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SharePointOnlineListLinkedService.java
@@ -0,0 +1,163 @@
+/**
+ * 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;
+
+/**
+ * SharePoint Online List linked service.
+ */
+@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type", defaultImpl = SharePointOnlineListLinkedService.class)
+@JsonTypeName("SharePointOnlineList")
+@JsonFlatten
+public class SharePointOnlineListLinkedService extends LinkedServiceInner {
+ /**
+ * The URL of the SharePoint Online site. For example,
+ * https://contoso.sharepoint.com/sites/siteName. Type: string (or
+ * Expression with resultType string).
+ */
+ @JsonProperty(value = "typeProperties.siteUrl", required = true)
+ private Object siteUrl;
+
+ /**
+ * The tenant ID under which your application resides. You can find it from
+ * Azure portal Active Directory overview page. Type: string (or Expression
+ * with resultType string).
+ */
+ @JsonProperty(value = "typeProperties.tenantId", required = true)
+ private Object tenantId;
+
+ /**
+ * The application (client) ID of your application registered in Azure
+ * Active Directory. Make sure to grant SharePoint site permission to this
+ * application. Type: string (or Expression with resultType string).
+ */
+ @JsonProperty(value = "typeProperties.servicePrincipalId", required = true)
+ private Object servicePrincipalId;
+
+ /**
+ * The client secret of your application registered in Azure Active
+ * Directory. Type: string (or Expression with resultType string).
+ */
+ @JsonProperty(value = "typeProperties.servicePrincipalKey", required = true)
+ private SecretBase servicePrincipalKey;
+
+ /**
+ * 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 the URL of the SharePoint Online site. For example, https://contoso.sharepoint.com/sites/siteName. Type: string (or Expression with resultType string).
+ *
+ * @return the siteUrl value
+ */
+ public Object siteUrl() {
+ return this.siteUrl;
+ }
+
+ /**
+ * Set the URL of the SharePoint Online site. For example, https://contoso.sharepoint.com/sites/siteName. Type: string (or Expression with resultType string).
+ *
+ * @param siteUrl the siteUrl value to set
+ * @return the SharePointOnlineListLinkedService object itself.
+ */
+ public SharePointOnlineListLinkedService withSiteUrl(Object siteUrl) {
+ this.siteUrl = siteUrl;
+ return this;
+ }
+
+ /**
+ * Get the tenant ID under which your application resides. You can find it from Azure portal Active Directory overview page. Type: string (or Expression with resultType string).
+ *
+ * @return the tenantId value
+ */
+ public Object tenantId() {
+ return this.tenantId;
+ }
+
+ /**
+ * Set the tenant ID under which your application resides. You can find it from Azure portal Active Directory overview page. Type: string (or Expression with resultType string).
+ *
+ * @param tenantId the tenantId value to set
+ * @return the SharePointOnlineListLinkedService object itself.
+ */
+ public SharePointOnlineListLinkedService withTenantId(Object tenantId) {
+ this.tenantId = tenantId;
+ return this;
+ }
+
+ /**
+ * Get the application (client) ID of your application registered in Azure Active Directory. Make sure to grant SharePoint site permission to this application. Type: string (or Expression with resultType string).
+ *
+ * @return the servicePrincipalId value
+ */
+ public Object servicePrincipalId() {
+ return this.servicePrincipalId;
+ }
+
+ /**
+ * Set the application (client) ID of your application registered in Azure Active Directory. Make sure to grant SharePoint site permission to this application. Type: string (or Expression with resultType string).
+ *
+ * @param servicePrincipalId the servicePrincipalId value to set
+ * @return the SharePointOnlineListLinkedService object itself.
+ */
+ public SharePointOnlineListLinkedService withServicePrincipalId(Object servicePrincipalId) {
+ this.servicePrincipalId = servicePrincipalId;
+ return this;
+ }
+
+ /**
+ * Get the client secret of your application registered in Azure Active Directory. Type: string (or Expression with resultType string).
+ *
+ * @return the servicePrincipalKey value
+ */
+ public SecretBase servicePrincipalKey() {
+ return this.servicePrincipalKey;
+ }
+
+ /**
+ * Set the client secret of your application registered in Azure Active Directory. Type: string (or Expression with resultType string).
+ *
+ * @param servicePrincipalKey the servicePrincipalKey value to set
+ * @return the SharePointOnlineListLinkedService object itself.
+ */
+ public SharePointOnlineListLinkedService withServicePrincipalKey(SecretBase servicePrincipalKey) {
+ this.servicePrincipalKey = servicePrincipalKey;
+ 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 SharePointOnlineListLinkedService object itself.
+ */
+ public SharePointOnlineListLinkedService 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/SharePointOnlineListResourceDataset.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SharePointOnlineListResourceDataset.java
new file mode 100644
index 0000000000000..036a57d56ba79
--- /dev/null
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SharePointOnlineListResourceDataset.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 sharepoint online list resource dataset.
+ */
+@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type", defaultImpl = SharePointOnlineListResourceDataset.class)
+@JsonTypeName("SharePointOnlineListResource")
+@JsonFlatten
+public class SharePointOnlineListResourceDataset extends DatasetInner {
+ /**
+ * The name of the SharePoint Online list. Type: string (or Expression with
+ * resultType string).
+ */
+ @JsonProperty(value = "typeProperties.listName")
+ private Object listName;
+
+ /**
+ * Get the name of the SharePoint Online list. Type: string (or Expression with resultType string).
+ *
+ * @return the listName value
+ */
+ public Object listName() {
+ return this.listName;
+ }
+
+ /**
+ * Set the name of the SharePoint Online list. Type: string (or Expression with resultType string).
+ *
+ * @param listName the listName value to set
+ * @return the SharePointOnlineListResourceDataset object itself.
+ */
+ public SharePointOnlineListResourceDataset withListName(Object listName) {
+ this.listName = listName;
+ return this;
+ }
+
+}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SharePointOnlineListSource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SharePointOnlineListSource.java
new file mode 100644
index 0000000000000..0ad953141b806
--- /dev/null
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SharePointOnlineListSource.java
@@ -0,0 +1,76 @@
+/**
+ * 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 source for sharePoint online list source.
+ */
+@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type", defaultImpl = SharePointOnlineListSource.class)
+@JsonTypeName("SharePointOnlineListSource")
+public class SharePointOnlineListSource extends CopySource {
+ /**
+ * The OData query to filter the data in SharePoint Online list. For
+ * example, "$top=1". Type: string (or Expression with resultType string).
+ */
+ @JsonProperty(value = "query")
+ private Object query;
+
+ /**
+ * The wait time to get a response from SharePoint Online. Default value is
+ * 5 minutes (00:05:00). Type: string (or Expression with resultType
+ * string), pattern: ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ */
+ @JsonProperty(value = "httpRequestTimeout")
+ private Object httpRequestTimeout;
+
+ /**
+ * Get the OData query to filter the data in SharePoint Online list. For example, "$top=1". Type: string (or Expression with resultType string).
+ *
+ * @return the query value
+ */
+ public Object query() {
+ return this.query;
+ }
+
+ /**
+ * Set the OData query to filter the data in SharePoint Online list. For example, "$top=1". Type: string (or Expression with resultType string).
+ *
+ * @param query the query value to set
+ * @return the SharePointOnlineListSource object itself.
+ */
+ public SharePointOnlineListSource withQuery(Object query) {
+ this.query = query;
+ return this;
+ }
+
+ /**
+ * Get the wait time to get a response from SharePoint Online. Default value is 5 minutes (00:05:00). Type: string (or Expression with resultType string), pattern: ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ *
+ * @return the httpRequestTimeout value
+ */
+ public Object httpRequestTimeout() {
+ return this.httpRequestTimeout;
+ }
+
+ /**
+ * Set the wait time to get a response from SharePoint Online. Default value is 5 minutes (00:05:00). Type: string (or Expression with resultType string), pattern: ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ *
+ * @param httpRequestTimeout the httpRequestTimeout value to set
+ * @return the SharePointOnlineListSource object itself.
+ */
+ public SharePointOnlineListSource withHttpRequestTimeout(Object httpRequestTimeout) {
+ this.httpRequestTimeout = httpRequestTimeout;
+ return this;
+ }
+
+}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SnowflakeDataset.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SnowflakeDataset.java
new file mode 100644
index 0000000000000..220b0b56517b9
--- /dev/null
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SnowflakeDataset.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;
+
+/**
+ * The snowflake dataset.
+ */
+@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type", defaultImpl = SnowflakeDataset.class)
+@JsonTypeName("SnowflakeTable")
+@JsonFlatten
+public class SnowflakeDataset extends DatasetInner {
+ /**
+ * The schema name of the Snowflake database. Type: string (or Expression
+ * with resultType string).
+ */
+ @JsonProperty(value = "typeProperties.schema")
+ private Object snowflakeDatasetSchema;
+
+ /**
+ * The table name of the Snowflake database. Type: string (or Expression
+ * with resultType string).
+ */
+ @JsonProperty(value = "typeProperties.table")
+ private Object table;
+
+ /**
+ * Get the schema name of the Snowflake database. Type: string (or Expression with resultType string).
+ *
+ * @return the snowflakeDatasetSchema value
+ */
+ public Object snowflakeDatasetSchema() {
+ return this.snowflakeDatasetSchema;
+ }
+
+ /**
+ * Set the schema name of the Snowflake database. Type: string (or Expression with resultType string).
+ *
+ * @param snowflakeDatasetSchema the snowflakeDatasetSchema value to set
+ * @return the SnowflakeDataset object itself.
+ */
+ public SnowflakeDataset withSnowflakeDatasetSchema(Object snowflakeDatasetSchema) {
+ this.snowflakeDatasetSchema = snowflakeDatasetSchema;
+ return this;
+ }
+
+ /**
+ * Get the table name of the Snowflake database. Type: string (or Expression with resultType string).
+ *
+ * @return the table value
+ */
+ public Object table() {
+ return this.table;
+ }
+
+ /**
+ * Set the table name of the Snowflake database. Type: string (or Expression with resultType string).
+ *
+ * @param table the table value to set
+ * @return the SnowflakeDataset object itself.
+ */
+ public SnowflakeDataset withTable(Object table) {
+ this.table = table;
+ return this;
+ }
+
+}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SnowflakeExportCopyCommand.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SnowflakeExportCopyCommand.java
new file mode 100644
index 0000000000000..f98578e97a571
--- /dev/null
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SnowflakeExportCopyCommand.java
@@ -0,0 +1,80 @@
+/**
+ * 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;
+
+/**
+ * Snowflake export command settings.
+ */
+@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type", defaultImpl = SnowflakeExportCopyCommand.class)
+@JsonTypeName("SnowflakeExportCopyCommand")
+public class SnowflakeExportCopyCommand extends ExportSettings {
+ /**
+ * Additional copy options directly passed to snowflake Copy Command. Type:
+ * key value pairs (value should be string type) (or Expression with
+ * resultType object). Example: "additionalCopyOptions": { "DATE_FORMAT":
+ * "MM/DD/YYYY", "TIME_FORMAT": "'HH24:MI:SS.FF'" }.
+ */
+ @JsonProperty(value = "additionalCopyOptions")
+ private Map additionalCopyOptions;
+
+ /**
+ * Additional format options directly passed to snowflake Copy Command.
+ * Type: key value pairs (value should be string type) (or Expression with
+ * resultType object). Example: "additionalFormatOptions": { "OVERWRITE":
+ * "TRUE", "MAX_FILE_SIZE": "'FALSE'" }.
+ */
+ @JsonProperty(value = "additionalFormatOptions")
+ private Map additionalFormatOptions;
+
+ /**
+ * Get additional copy options directly passed to snowflake Copy Command. Type: key value pairs (value should be string type) (or Expression with resultType object). Example: "additionalCopyOptions": { "DATE_FORMAT": "MM/DD/YYYY", "TIME_FORMAT": "'HH24:MI:SS.FF'" }.
+ *
+ * @return the additionalCopyOptions value
+ */
+ public Map additionalCopyOptions() {
+ return this.additionalCopyOptions;
+ }
+
+ /**
+ * Set additional copy options directly passed to snowflake Copy Command. Type: key value pairs (value should be string type) (or Expression with resultType object). Example: "additionalCopyOptions": { "DATE_FORMAT": "MM/DD/YYYY", "TIME_FORMAT": "'HH24:MI:SS.FF'" }.
+ *
+ * @param additionalCopyOptions the additionalCopyOptions value to set
+ * @return the SnowflakeExportCopyCommand object itself.
+ */
+ public SnowflakeExportCopyCommand withAdditionalCopyOptions(Map additionalCopyOptions) {
+ this.additionalCopyOptions = additionalCopyOptions;
+ return this;
+ }
+
+ /**
+ * Get additional format options directly passed to snowflake Copy Command. Type: key value pairs (value should be string type) (or Expression with resultType object). Example: "additionalFormatOptions": { "OVERWRITE": "TRUE", "MAX_FILE_SIZE": "'FALSE'" }.
+ *
+ * @return the additionalFormatOptions value
+ */
+ public Map additionalFormatOptions() {
+ return this.additionalFormatOptions;
+ }
+
+ /**
+ * Set additional format options directly passed to snowflake Copy Command. Type: key value pairs (value should be string type) (or Expression with resultType object). Example: "additionalFormatOptions": { "OVERWRITE": "TRUE", "MAX_FILE_SIZE": "'FALSE'" }.
+ *
+ * @param additionalFormatOptions the additionalFormatOptions value to set
+ * @return the SnowflakeExportCopyCommand object itself.
+ */
+ public SnowflakeExportCopyCommand withAdditionalFormatOptions(Map additionalFormatOptions) {
+ this.additionalFormatOptions = additionalFormatOptions;
+ return this;
+ }
+
+}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SnowflakeImportCopyCommand.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SnowflakeImportCopyCommand.java
new file mode 100644
index 0000000000000..200645c825705
--- /dev/null
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SnowflakeImportCopyCommand.java
@@ -0,0 +1,80 @@
+/**
+ * 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;
+
+/**
+ * Snowflake import command settings.
+ */
+@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type", defaultImpl = SnowflakeImportCopyCommand.class)
+@JsonTypeName("SnowflakeImportCopyCommand")
+public class SnowflakeImportCopyCommand extends ImportSettings {
+ /**
+ * Additional copy options directly passed to snowflake Copy Command. Type:
+ * key value pairs (value should be string type) (or Expression with
+ * resultType object). Example: "additionalCopyOptions": { "DATE_FORMAT":
+ * "MM/DD/YYYY", "TIME_FORMAT": "'HH24:MI:SS.FF'" }.
+ */
+ @JsonProperty(value = "additionalCopyOptions")
+ private Map additionalCopyOptions;
+
+ /**
+ * Additional format options directly passed to snowflake Copy Command.
+ * Type: key value pairs (value should be string type) (or Expression with
+ * resultType object). Example: "additionalFormatOptions": { "FORCE":
+ * "TRUE", "LOAD_UNCERTAIN_FILES": "'FALSE'" }.
+ */
+ @JsonProperty(value = "additionalFormatOptions")
+ private Map additionalFormatOptions;
+
+ /**
+ * Get additional copy options directly passed to snowflake Copy Command. Type: key value pairs (value should be string type) (or Expression with resultType object). Example: "additionalCopyOptions": { "DATE_FORMAT": "MM/DD/YYYY", "TIME_FORMAT": "'HH24:MI:SS.FF'" }.
+ *
+ * @return the additionalCopyOptions value
+ */
+ public Map additionalCopyOptions() {
+ return this.additionalCopyOptions;
+ }
+
+ /**
+ * Set additional copy options directly passed to snowflake Copy Command. Type: key value pairs (value should be string type) (or Expression with resultType object). Example: "additionalCopyOptions": { "DATE_FORMAT": "MM/DD/YYYY", "TIME_FORMAT": "'HH24:MI:SS.FF'" }.
+ *
+ * @param additionalCopyOptions the additionalCopyOptions value to set
+ * @return the SnowflakeImportCopyCommand object itself.
+ */
+ public SnowflakeImportCopyCommand withAdditionalCopyOptions(Map additionalCopyOptions) {
+ this.additionalCopyOptions = additionalCopyOptions;
+ return this;
+ }
+
+ /**
+ * Get additional format options directly passed to snowflake Copy Command. Type: key value pairs (value should be string type) (or Expression with resultType object). Example: "additionalFormatOptions": { "FORCE": "TRUE", "LOAD_UNCERTAIN_FILES": "'FALSE'" }.
+ *
+ * @return the additionalFormatOptions value
+ */
+ public Map additionalFormatOptions() {
+ return this.additionalFormatOptions;
+ }
+
+ /**
+ * Set additional format options directly passed to snowflake Copy Command. Type: key value pairs (value should be string type) (or Expression with resultType object). Example: "additionalFormatOptions": { "FORCE": "TRUE", "LOAD_UNCERTAIN_FILES": "'FALSE'" }.
+ *
+ * @param additionalFormatOptions the additionalFormatOptions value to set
+ * @return the SnowflakeImportCopyCommand object itself.
+ */
+ public SnowflakeImportCopyCommand withAdditionalFormatOptions(Map additionalFormatOptions) {
+ this.additionalFormatOptions = additionalFormatOptions;
+ return this;
+ }
+
+}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SnowflakeLinkedService.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SnowflakeLinkedService.java
new file mode 100644
index 0000000000000..770dfadbff8f0
--- /dev/null
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SnowflakeLinkedService.java
@@ -0,0 +1,104 @@
+/**
+ * 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;
+
+/**
+ * Snowflake linked service.
+ */
+@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type", defaultImpl = SnowflakeLinkedService.class)
+@JsonTypeName("Snowflake")
+@JsonFlatten
+public class SnowflakeLinkedService extends LinkedServiceInner {
+ /**
+ * The connection string of snowflake. Type: string, SecureString.
+ */
+ @JsonProperty(value = "typeProperties.connectionString", required = true)
+ private Object connectionString;
+
+ /**
+ * The Azure key vault secret reference of password in connection string.
+ */
+ @JsonProperty(value = "typeProperties.password")
+ private AzureKeyVaultSecretReference password;
+
+ /**
+ * 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 the connection string of snowflake. Type: string, SecureString.
+ *
+ * @return the connectionString value
+ */
+ public Object connectionString() {
+ return this.connectionString;
+ }
+
+ /**
+ * Set the connection string of snowflake. Type: string, SecureString.
+ *
+ * @param connectionString the connectionString value to set
+ * @return the SnowflakeLinkedService object itself.
+ */
+ public SnowflakeLinkedService withConnectionString(Object connectionString) {
+ this.connectionString = connectionString;
+ return this;
+ }
+
+ /**
+ * Get the Azure key vault secret reference of password in connection string.
+ *
+ * @return the password value
+ */
+ public AzureKeyVaultSecretReference password() {
+ return this.password;
+ }
+
+ /**
+ * Set the Azure key vault secret reference of password in connection string.
+ *
+ * @param password the password value to set
+ * @return the SnowflakeLinkedService object itself.
+ */
+ public SnowflakeLinkedService withPassword(AzureKeyVaultSecretReference password) {
+ this.password = password;
+ 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 SnowflakeLinkedService object itself.
+ */
+ public SnowflakeLinkedService 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/SnowflakeSink.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SnowflakeSink.java
new file mode 100644
index 0000000000000..bed7874db1d6e
--- /dev/null
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SnowflakeSink.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 snowflake sink.
+ */
+@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type", defaultImpl = SnowflakeSink.class)
+@JsonTypeName("SnowflakeSink")
+public class SnowflakeSink extends CopySink {
+ /**
+ * SQL pre-copy script. Type: string (or Expression with resultType
+ * string).
+ */
+ @JsonProperty(value = "preCopyScript")
+ private Object preCopyScript;
+
+ /**
+ * Snowflake import settings.
+ */
+ @JsonProperty(value = "importSettings")
+ private SnowflakeImportCopyCommand 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 SnowflakeSink object itself.
+ */
+ public SnowflakeSink withPreCopyScript(Object preCopyScript) {
+ this.preCopyScript = preCopyScript;
+ return this;
+ }
+
+ /**
+ * Get snowflake import settings.
+ *
+ * @return the importSettings value
+ */
+ public SnowflakeImportCopyCommand importSettings() {
+ return this.importSettings;
+ }
+
+ /**
+ * Set snowflake import settings.
+ *
+ * @param importSettings the importSettings value to set
+ * @return the SnowflakeSink object itself.
+ */
+ public SnowflakeSink withImportSettings(SnowflakeImportCopyCommand 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/SnowflakeSource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SnowflakeSource.java
new file mode 100644
index 0000000000000..c9406c096e17b
--- /dev/null
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SnowflakeSource.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 snowflake source.
+ */
+@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type", defaultImpl = SnowflakeSource.class)
+@JsonTypeName("SnowflakeSource")
+public class SnowflakeSource extends CopySource {
+ /**
+ * Snowflake Sql query. Type: string (or Expression with resultType
+ * string).
+ */
+ @JsonProperty(value = "query")
+ private Object query;
+
+ /**
+ * Snowflake export settings.
+ */
+ @JsonProperty(value = "exportSettings")
+ private SnowflakeExportCopyCommand exportSettings;
+
+ /**
+ * Get snowflake Sql query. Type: string (or Expression with resultType string).
+ *
+ * @return the query value
+ */
+ public Object query() {
+ return this.query;
+ }
+
+ /**
+ * Set snowflake Sql query. Type: string (or Expression with resultType string).
+ *
+ * @param query the query value to set
+ * @return the SnowflakeSource object itself.
+ */
+ public SnowflakeSource withQuery(Object query) {
+ this.query = query;
+ return this;
+ }
+
+ /**
+ * Get snowflake export settings.
+ *
+ * @return the exportSettings value
+ */
+ public SnowflakeExportCopyCommand exportSettings() {
+ return this.exportSettings;
+ }
+
+ /**
+ * Set snowflake export settings.
+ *
+ * @param exportSettings the exportSettings value to set
+ * @return the SnowflakeSource object itself.
+ */
+ public SnowflakeSource withExportSettings(SnowflakeExportCopyCommand 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/SqlDWSource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SqlDWSource.java
index c7fff34254a22..30aa16d72df20 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SqlDWSource.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SqlDWSource.java
@@ -41,6 +41,20 @@ public class SqlDWSource extends TabularSource {
@JsonProperty(value = "storedProcedureParameters")
private Object storedProcedureParameters;
+ /**
+ * The partition mechanism that will be used for Sql read in parallel.
+ * Possible values include: 'None', 'PhysicalPartitionsOfTable',
+ * 'DynamicRange'.
+ */
+ @JsonProperty(value = "partitionOption")
+ private SqlPartitionOption partitionOption;
+
+ /**
+ * The settings that will be leveraged for Sql source partitioning.
+ */
+ @JsonProperty(value = "partitionSettings")
+ private SqlPartitionSettings partitionSettings;
+
/**
* Get sQL Data Warehouse reader query. Type: string (or Expression with resultType string).
*
@@ -101,4 +115,44 @@ public SqlDWSource withStoredProcedureParameters(Object storedProcedureParameter
return this;
}
+ /**
+ * Get the partition mechanism that will be used for Sql read in parallel. Possible values include: 'None', 'PhysicalPartitionsOfTable', 'DynamicRange'.
+ *
+ * @return the partitionOption value
+ */
+ public SqlPartitionOption partitionOption() {
+ return this.partitionOption;
+ }
+
+ /**
+ * Set the partition mechanism that will be used for Sql read in parallel. Possible values include: 'None', 'PhysicalPartitionsOfTable', 'DynamicRange'.
+ *
+ * @param partitionOption the partitionOption value to set
+ * @return the SqlDWSource object itself.
+ */
+ public SqlDWSource withPartitionOption(SqlPartitionOption partitionOption) {
+ this.partitionOption = partitionOption;
+ return this;
+ }
+
+ /**
+ * Get the settings that will be leveraged for Sql source partitioning.
+ *
+ * @return the partitionSettings value
+ */
+ public SqlPartitionSettings partitionSettings() {
+ return this.partitionSettings;
+ }
+
+ /**
+ * Set the settings that will be leveraged for Sql source partitioning.
+ *
+ * @param partitionSettings the partitionSettings value to set
+ * @return the SqlDWSource object itself.
+ */
+ public SqlDWSource withPartitionSettings(SqlPartitionSettings partitionSettings) {
+ this.partitionSettings = partitionSettings;
+ return this;
+ }
+
}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SqlMISource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SqlMISource.java
index 381d35dbd9f84..9800904b732c9 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SqlMISource.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SqlMISource.java
@@ -46,6 +46,20 @@ public class SqlMISource extends TabularSource {
@JsonProperty(value = "produceAdditionalTypes")
private Object produceAdditionalTypes;
+ /**
+ * The partition mechanism that will be used for Sql read in parallel.
+ * Possible values include: 'None', 'PhysicalPartitionsOfTable',
+ * 'DynamicRange'.
+ */
+ @JsonProperty(value = "partitionOption")
+ private SqlPartitionOption partitionOption;
+
+ /**
+ * The settings that will be leveraged for Sql source partitioning.
+ */
+ @JsonProperty(value = "partitionSettings")
+ private SqlPartitionSettings partitionSettings;
+
/**
* Get sQL reader query. Type: string (or Expression with resultType string).
*
@@ -126,4 +140,44 @@ public SqlMISource withProduceAdditionalTypes(Object produceAdditionalTypes) {
return this;
}
+ /**
+ * Get the partition mechanism that will be used for Sql read in parallel. Possible values include: 'None', 'PhysicalPartitionsOfTable', 'DynamicRange'.
+ *
+ * @return the partitionOption value
+ */
+ public SqlPartitionOption partitionOption() {
+ return this.partitionOption;
+ }
+
+ /**
+ * Set the partition mechanism that will be used for Sql read in parallel. Possible values include: 'None', 'PhysicalPartitionsOfTable', 'DynamicRange'.
+ *
+ * @param partitionOption the partitionOption value to set
+ * @return the SqlMISource object itself.
+ */
+ public SqlMISource withPartitionOption(SqlPartitionOption partitionOption) {
+ this.partitionOption = partitionOption;
+ return this;
+ }
+
+ /**
+ * Get the settings that will be leveraged for Sql source partitioning.
+ *
+ * @return the partitionSettings value
+ */
+ public SqlPartitionSettings partitionSettings() {
+ return this.partitionSettings;
+ }
+
+ /**
+ * Set the settings that will be leveraged for Sql source partitioning.
+ *
+ * @param partitionSettings the partitionSettings value to set
+ * @return the SqlMISource object itself.
+ */
+ public SqlMISource withPartitionSettings(SqlPartitionSettings partitionSettings) {
+ this.partitionSettings = partitionSettings;
+ return this;
+ }
+
}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SqlPartitionOption.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SqlPartitionOption.java
new file mode 100644
index 0000000000000..2f2827b25bff3
--- /dev/null
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SqlPartitionOption.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 SqlPartitionOption.
+ */
+public final class SqlPartitionOption extends ExpandableStringEnum {
+ /** Static value None for SqlPartitionOption. */
+ public static final SqlPartitionOption NONE = fromString("None");
+
+ /** Static value PhysicalPartitionsOfTable for SqlPartitionOption. */
+ public static final SqlPartitionOption PHYSICAL_PARTITIONS_OF_TABLE = fromString("PhysicalPartitionsOfTable");
+
+ /** Static value DynamicRange for SqlPartitionOption. */
+ public static final SqlPartitionOption DYNAMIC_RANGE = fromString("DynamicRange");
+
+ /**
+ * Creates or finds a SqlPartitionOption from its string representation.
+ * @param name a name to look for
+ * @return the corresponding SqlPartitionOption
+ */
+ @JsonCreator
+ public static SqlPartitionOption fromString(String name) {
+ return fromString(name, SqlPartitionOption.class);
+ }
+
+ /**
+ * @return known SqlPartitionOption values
+ */
+ public static Collection values() {
+ return values(SqlPartitionOption.class);
+ }
+}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SqlPartitionSettings.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SqlPartitionSettings.java
new file mode 100644
index 0000000000000..7c53f62e590b5
--- /dev/null
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SqlPartitionSettings.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;
+
+/**
+ * The settings that will be leveraged for Sql source partitioning.
+ */
+public class SqlPartitionSettings {
+ /**
+ * The name of the column in integer or datetime type that will be used for
+ * proceeding partitioning. If not specified, the primary key of the table
+ * is auto-detected and used as the partition column. Type: string (or
+ * Expression with resultType string).
+ */
+ @JsonProperty(value = "partitionColumnName")
+ private Object partitionColumnName;
+
+ /**
+ * The maximum value of column specified in partitionColumnName that will
+ * be used for proceeding range partitioning. Type: string (or Expression
+ * with resultType string).
+ */
+ @JsonProperty(value = "partitionUpperBound")
+ private Object partitionUpperBound;
+
+ /**
+ * The minimum value of column specified in partitionColumnName that will
+ * be used for proceeding range partitioning. Type: string (or Expression
+ * with resultType string).
+ */
+ @JsonProperty(value = "partitionLowerBound")
+ private Object partitionLowerBound;
+
+ /**
+ * Get the name of the column in integer or datetime type that will be used for proceeding partitioning. If not specified, the primary key of the table is auto-detected and used as the partition column. Type: string (or Expression with resultType string).
+ *
+ * @return the partitionColumnName value
+ */
+ public Object partitionColumnName() {
+ return this.partitionColumnName;
+ }
+
+ /**
+ * Set the name of the column in integer or datetime type that will be used for proceeding partitioning. If not specified, the primary key of the table is auto-detected and used as the partition column. Type: string (or Expression with resultType string).
+ *
+ * @param partitionColumnName the partitionColumnName value to set
+ * @return the SqlPartitionSettings object itself.
+ */
+ public SqlPartitionSettings withPartitionColumnName(Object partitionColumnName) {
+ this.partitionColumnName = partitionColumnName;
+ return this;
+ }
+
+ /**
+ * Get the maximum value of column specified in partitionColumnName that will be used for proceeding range partitioning. Type: string (or Expression with resultType string).
+ *
+ * @return the partitionUpperBound value
+ */
+ public Object partitionUpperBound() {
+ return this.partitionUpperBound;
+ }
+
+ /**
+ * Set the maximum value of column specified in partitionColumnName that will be used for proceeding range partitioning. Type: string (or Expression with resultType string).
+ *
+ * @param partitionUpperBound the partitionUpperBound value to set
+ * @return the SqlPartitionSettings object itself.
+ */
+ public SqlPartitionSettings withPartitionUpperBound(Object partitionUpperBound) {
+ this.partitionUpperBound = partitionUpperBound;
+ return this;
+ }
+
+ /**
+ * Get the minimum value of column specified in partitionColumnName that will be used for proceeding range partitioning. Type: string (or Expression with resultType string).
+ *
+ * @return the partitionLowerBound value
+ */
+ public Object partitionLowerBound() {
+ return this.partitionLowerBound;
+ }
+
+ /**
+ * Set the minimum value of column specified in partitionColumnName that will be used for proceeding range partitioning. Type: string (or Expression with resultType string).
+ *
+ * @param partitionLowerBound the partitionLowerBound value to set
+ * @return the SqlPartitionSettings object itself.
+ */
+ public SqlPartitionSettings withPartitionLowerBound(Object partitionLowerBound) {
+ this.partitionLowerBound = partitionLowerBound;
+ return this;
+ }
+
+}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SqlServerSource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SqlServerSource.java
index 3b45fc157aecf..3a678a0a374fa 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SqlServerSource.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SqlServerSource.java
@@ -46,6 +46,20 @@ public class SqlServerSource extends TabularSource {
@JsonProperty(value = "produceAdditionalTypes")
private Object produceAdditionalTypes;
+ /**
+ * The partition mechanism that will be used for Sql read in parallel.
+ * Possible values include: 'None', 'PhysicalPartitionsOfTable',
+ * 'DynamicRange'.
+ */
+ @JsonProperty(value = "partitionOption")
+ private SqlPartitionOption partitionOption;
+
+ /**
+ * The settings that will be leveraged for Sql source partitioning.
+ */
+ @JsonProperty(value = "partitionSettings")
+ private SqlPartitionSettings partitionSettings;
+
/**
* Get sQL reader query. Type: string (or Expression with resultType string).
*
@@ -126,4 +140,44 @@ public SqlServerSource withProduceAdditionalTypes(Object produceAdditionalTypes)
return this;
}
+ /**
+ * Get the partition mechanism that will be used for Sql read in parallel. Possible values include: 'None', 'PhysicalPartitionsOfTable', 'DynamicRange'.
+ *
+ * @return the partitionOption value
+ */
+ public SqlPartitionOption partitionOption() {
+ return this.partitionOption;
+ }
+
+ /**
+ * Set the partition mechanism that will be used for Sql read in parallel. Possible values include: 'None', 'PhysicalPartitionsOfTable', 'DynamicRange'.
+ *
+ * @param partitionOption the partitionOption value to set
+ * @return the SqlServerSource object itself.
+ */
+ public SqlServerSource withPartitionOption(SqlPartitionOption partitionOption) {
+ this.partitionOption = partitionOption;
+ return this;
+ }
+
+ /**
+ * Get the settings that will be leveraged for Sql source partitioning.
+ *
+ * @return the partitionSettings value
+ */
+ public SqlPartitionSettings partitionSettings() {
+ return this.partitionSettings;
+ }
+
+ /**
+ * Set the settings that will be leveraged for Sql source partitioning.
+ *
+ * @param partitionSettings the partitionSettings value to set
+ * @return the SqlServerSource object itself.
+ */
+ public SqlServerSource withPartitionSettings(SqlPartitionSettings partitionSettings) {
+ this.partitionSettings = partitionSettings;
+ return this;
+ }
+
}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SqlSource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SqlSource.java
index 771a81b9058f4..5122513466364 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SqlSource.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SqlSource.java
@@ -50,6 +50,20 @@ public class SqlSource extends TabularSource {
@JsonProperty(value = "isolationLevel")
private Object isolationLevel;
+ /**
+ * The partition mechanism that will be used for Sql read in parallel.
+ * Possible values include: 'None', 'PhysicalPartitionsOfTable',
+ * 'DynamicRange'.
+ */
+ @JsonProperty(value = "partitionOption")
+ private SqlPartitionOption partitionOption;
+
+ /**
+ * The settings that will be leveraged for Sql source partitioning.
+ */
+ @JsonProperty(value = "partitionSettings")
+ private SqlPartitionSettings partitionSettings;
+
/**
* Get sQL reader query. Type: string (or Expression with resultType string).
*
@@ -130,4 +144,44 @@ public SqlSource withIsolationLevel(Object isolationLevel) {
return this;
}
+ /**
+ * Get the partition mechanism that will be used for Sql read in parallel. Possible values include: 'None', 'PhysicalPartitionsOfTable', 'DynamicRange'.
+ *
+ * @return the partitionOption value
+ */
+ public SqlPartitionOption partitionOption() {
+ return this.partitionOption;
+ }
+
+ /**
+ * Set the partition mechanism that will be used for Sql read in parallel. Possible values include: 'None', 'PhysicalPartitionsOfTable', 'DynamicRange'.
+ *
+ * @param partitionOption the partitionOption value to set
+ * @return the SqlSource object itself.
+ */
+ public SqlSource withPartitionOption(SqlPartitionOption partitionOption) {
+ this.partitionOption = partitionOption;
+ return this;
+ }
+
+ /**
+ * Get the settings that will be leveraged for Sql source partitioning.
+ *
+ * @return the partitionSettings value
+ */
+ public SqlPartitionSettings partitionSettings() {
+ return this.partitionSettings;
+ }
+
+ /**
+ * Set the settings that will be leveraged for Sql source partitioning.
+ *
+ * @param partitionSettings the partitionSettings value to set
+ * @return the SqlSource object itself.
+ */
+ public SqlSource withPartitionSettings(SqlPartitionSettings partitionSettings) {
+ this.partitionSettings = partitionSettings;
+ return this;
+ }
+
}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SsisPackageLocationType.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SsisPackageLocationType.java
index bb3ccf778cd60..dc99b6f2860f1 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SsisPackageLocationType.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SsisPackageLocationType.java
@@ -25,6 +25,9 @@ public final class SsisPackageLocationType extends ExpandableStringEnum