diff --git a/sdk/datafactory/mgmt-v2018_06_01/pom.xml b/sdk/datafactory/mgmt-v2018_06_01/pom.xml
index a4de696b8d205..e74ba7e1edb9a 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.2.0
+ 1.3.0
../../../pom.management.xml
azure-mgmt-datafactory
- 1.0.0-beta
+ 1.0.0-beta-1
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/AdditionalColumns.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AdditionalColumns.java
new file mode 100644
index 0000000000000..13ddd2f002af9
--- /dev/null
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AdditionalColumns.java
@@ -0,0 +1,71 @@
+/**
+ * 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;
+
+/**
+ * Specify the column name and value of additional columns.
+ */
+public class AdditionalColumns {
+ /**
+ * Additional column name. Type: string (or Expression with resultType
+ * string).
+ */
+ @JsonProperty(value = "name")
+ private Object name;
+
+ /**
+ * Additional column value. Type: string (or Expression with resultType
+ * string).
+ */
+ @JsonProperty(value = "value")
+ private Object value;
+
+ /**
+ * Get additional column name. Type: string (or Expression with resultType string).
+ *
+ * @return the name value
+ */
+ public Object name() {
+ return this.name;
+ }
+
+ /**
+ * Set additional column name. Type: string (or Expression with resultType string).
+ *
+ * @param name the name value to set
+ * @return the AdditionalColumns object itself.
+ */
+ public AdditionalColumns withName(Object name) {
+ this.name = name;
+ return this;
+ }
+
+ /**
+ * Get additional column value. Type: string (or Expression with resultType string).
+ *
+ * @return the value value
+ */
+ public Object value() {
+ return this.value;
+ }
+
+ /**
+ * Set additional column value. Type: string (or Expression with resultType string).
+ *
+ * @param value the value value to set
+ * @return the AdditionalColumns object itself.
+ */
+ public AdditionalColumns withValue(Object value) {
+ this.value = value;
+ return this;
+ }
+
+}
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 a32d45ffdd130..60113210f030f 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
@@ -46,6 +46,14 @@ public class AmazonS3ReadSettings extends StoreReadSettings {
@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
+ * Expression with resultType string).
+ */
+ @JsonProperty(value = "fileListPath")
+ private Object fileListPath;
+
/**
* Indicates whether to enable partition discovery.
*/
@@ -146,6 +154,26 @@ public AmazonS3ReadSettings withPrefix(Object 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).
+ *
+ * @return the fileListPath value
+ */
+ public Object fileListPath() {
+ return this.fileListPath;
+ }
+
+ /**
+ * Set 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).
+ *
+ * @param fileListPath the fileListPath value to set
+ * @return the AmazonS3ReadSettings object itself.
+ */
+ public AmazonS3ReadSettings withFileListPath(Object fileListPath) {
+ this.fileListPath = fileListPath;
+ return this;
+ }
+
/**
* Get indicates whether to enable partition discovery.
*
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AvroSource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AvroSource.java
index d03ef1cb0b7d9..9adafd898a9ce 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AvroSource.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AvroSource.java
@@ -8,6 +8,7 @@
package com.microsoft.azure.management.datafactory.v2018_06_01;
+import java.util.List;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonTypeInfo;
import com.fasterxml.jackson.annotation.JsonTypeName;
@@ -24,6 +25,13 @@ public class AvroSource extends CopySource {
@JsonProperty(value = "storeSettings")
private StoreReadSettings storeSettings;
+ /**
+ * Specifies the additional columns to be added to source data. Type: array
+ * of objects (or Expression with resultType array of objects).
+ */
+ @JsonProperty(value = "additionalColumns")
+ private List additionalColumns;
+
/**
* Get avro store settings.
*
@@ -44,4 +52,24 @@ public AvroSource withStoreSettings(StoreReadSettings storeSettings) {
return this;
}
+ /**
+ * Get specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @return the additionalColumns value
+ */
+ public List additionalColumns() {
+ return this.additionalColumns;
+ }
+
+ /**
+ * Set specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @param additionalColumns the additionalColumns value to set
+ * @return the AvroSource object itself.
+ */
+ public AvroSource withAdditionalColumns(List additionalColumns) {
+ this.additionalColumns = additionalColumns;
+ return this;
+ }
+
}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureBlobFSReadSettings.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureBlobFSReadSettings.java
index f3ac479fdbfd3..dc4d0edbdee3b 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
@@ -39,6 +39,14 @@ public class AzureBlobFSReadSettings extends StoreReadSettings {
@JsonProperty(value = "wildcardFileName")
private Object wildcardFileName;
+ /**
+ * 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).
+ */
+ @JsonProperty(value = "fileListPath")
+ private Object fileListPath;
+
/**
* Indicates whether to enable partition discovery.
*/
@@ -119,6 +127,26 @@ public AzureBlobFSReadSettings withWildcardFileName(Object wildcardFileName) {
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).
+ *
+ * @return the fileListPath value
+ */
+ public Object fileListPath() {
+ return this.fileListPath;
+ }
+
+ /**
+ * Set 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).
+ *
+ * @param fileListPath the fileListPath value to set
+ * @return the AzureBlobFSReadSettings object itself.
+ */
+ public AzureBlobFSReadSettings withFileListPath(Object fileListPath) {
+ this.fileListPath = fileListPath;
+ return this;
+ }
+
/**
* Get indicates whether to enable partition discovery.
*
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 975f8003e8408..7f42a713ccf5e 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
@@ -46,6 +46,14 @@ public class AzureBlobStorageReadSettings extends StoreReadSettings {
@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
+ * Expression with resultType string).
+ */
+ @JsonProperty(value = "fileListPath")
+ private Object fileListPath;
+
/**
* Indicates whether to enable partition discovery.
*/
@@ -146,6 +154,26 @@ public AzureBlobStorageReadSettings withPrefix(Object 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).
+ *
+ * @return the fileListPath value
+ */
+ public Object fileListPath() {
+ return this.fileListPath;
+ }
+
+ /**
+ * Set 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).
+ *
+ * @param fileListPath the fileListPath value to set
+ * @return the AzureBlobStorageReadSettings object itself.
+ */
+ public AzureBlobStorageReadSettings withFileListPath(Object fileListPath) {
+ this.fileListPath = fileListPath;
+ return this;
+ }
+
/**
* Get indicates whether to enable partition discovery.
*
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureDataExplorerSource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureDataExplorerSource.java
index 11e92095f0209..60e5ff128c18a 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureDataExplorerSource.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureDataExplorerSource.java
@@ -8,6 +8,7 @@
package com.microsoft.azure.management.datafactory.v2018_06_01;
+import java.util.List;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonTypeInfo;
import com.fasterxml.jackson.annotation.JsonTypeName;
@@ -39,6 +40,13 @@ public class AzureDataExplorerSource extends CopySource {
@JsonProperty(value = "queryTimeout")
private Object queryTimeout;
+ /**
+ * Specifies the additional columns to be added to source data. Type: array
+ * of objects (or Expression with resultType array of objects).
+ */
+ @JsonProperty(value = "additionalColumns")
+ private List additionalColumns;
+
/**
* Get database query. Should be a Kusto Query Language (KQL) query. Type: string (or Expression with resultType string).
*
@@ -99,4 +107,24 @@ public AzureDataExplorerSource withQueryTimeout(Object queryTimeout) {
return this;
}
+ /**
+ * Get specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @return the additionalColumns value
+ */
+ public List additionalColumns() {
+ return this.additionalColumns;
+ }
+
+ /**
+ * Set specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @param additionalColumns the additionalColumns value to set
+ * @return the AzureDataExplorerSource object itself.
+ */
+ public AzureDataExplorerSource withAdditionalColumns(List additionalColumns) {
+ this.additionalColumns = additionalColumns;
+ return this;
+ }
+
}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureDataLakeStoreReadSettings.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureDataLakeStoreReadSettings.java
index 4fbb2f602b70a..98d24cedeec25 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
@@ -39,6 +39,14 @@ public class AzureDataLakeStoreReadSettings extends StoreReadSettings {
@JsonProperty(value = "wildcardFileName")
private Object wildcardFileName;
+ /**
+ * 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).
+ */
+ @JsonProperty(value = "fileListPath")
+ private Object fileListPath;
+
/**
* Indicates whether to enable partition discovery.
*/
@@ -119,6 +127,26 @@ public AzureDataLakeStoreReadSettings withWildcardFileName(Object wildcardFileNa
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).
+ *
+ * @return the fileListPath value
+ */
+ public Object fileListPath() {
+ return this.fileListPath;
+ }
+
+ /**
+ * Set 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).
+ *
+ * @param fileListPath the fileListPath value to set
+ * @return the AzureDataLakeStoreReadSettings object itself.
+ */
+ public AzureDataLakeStoreReadSettings withFileListPath(Object fileListPath) {
+ this.fileListPath = fileListPath;
+ return this;
+ }
+
/**
* Get indicates whether to enable partition discovery.
*
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureDataLakeStoreWriteSettings.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureDataLakeStoreWriteSettings.java
index 7b2025efec19c..96f972a5c4696 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureDataLakeStoreWriteSettings.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureDataLakeStoreWriteSettings.java
@@ -8,6 +8,7 @@
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;
@@ -17,4 +18,32 @@
@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type", defaultImpl = AzureDataLakeStoreWriteSettings.class)
@JsonTypeName("AzureDataLakeStoreWriteSettings")
public class AzureDataLakeStoreWriteSettings extends StoreWriteSettings {
+ /**
+ * Specifies the expiry time of the written files. The time is applied to
+ * the UTC time zone in the format of "2018-12-01T05:00:00Z". Default value
+ * is NULL. Type: integer (or Expression with resultType integer).
+ */
+ @JsonProperty(value = "expiryDateTime")
+ private Object expiryDateTime;
+
+ /**
+ * Get specifies the expiry time of the written files. The time is applied to the UTC time zone in the format of "2018-12-01T05:00:00Z". Default value is NULL. Type: integer (or Expression with resultType integer).
+ *
+ * @return the expiryDateTime value
+ */
+ public Object expiryDateTime() {
+ return this.expiryDateTime;
+ }
+
+ /**
+ * Set specifies the expiry time of the written files. The time is applied to the UTC time zone in the format of "2018-12-01T05:00:00Z". Default value is NULL. Type: integer (or Expression with resultType integer).
+ *
+ * @param expiryDateTime the expiryDateTime value to set
+ * @return the AzureDataLakeStoreWriteSettings object itself.
+ */
+ public AzureDataLakeStoreWriteSettings withExpiryDateTime(Object expiryDateTime) {
+ this.expiryDateTime = expiryDateTime;
+ return this;
+ }
+
}
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 d919a92b822bb..174897feba009 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,14 @@ public class AzureFileStorageReadSettings extends StoreReadSettings {
@JsonProperty(value = "wildcardFileName")
private Object wildcardFileName;
+ /**
+ * 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).
+ */
+ @JsonProperty(value = "fileListPath")
+ private Object fileListPath;
+
/**
* Indicates whether to enable partition discovery.
*/
@@ -119,6 +127,26 @@ public AzureFileStorageReadSettings withWildcardFileName(Object wildcardFileName
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).
+ *
+ * @return the fileListPath value
+ */
+ public Object fileListPath() {
+ return this.fileListPath;
+ }
+
+ /**
+ * Set 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).
+ *
+ * @param fileListPath the fileListPath value to set
+ * @return the AzureFileStorageReadSettings object itself.
+ */
+ public AzureFileStorageReadSettings withFileListPath(Object fileListPath) {
+ this.fileListPath = fileListPath;
+ return this;
+ }
+
/**
* Get indicates whether to enable partition discovery.
*
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CommonDataServiceForAppsSource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CommonDataServiceForAppsSource.java
index 45fe926b1d2ff..374a85c45a704 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CommonDataServiceForAppsSource.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CommonDataServiceForAppsSource.java
@@ -8,6 +8,7 @@
package com.microsoft.azure.management.datafactory.v2018_06_01;
+import java.util.List;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonTypeInfo;
import com.fasterxml.jackson.annotation.JsonTypeName;
@@ -26,6 +27,13 @@ public class CommonDataServiceForAppsSource extends CopySource {
@JsonProperty(value = "query")
private Object query;
+ /**
+ * Specifies the additional columns to be added to source data. Type: array
+ * of objects (or Expression with resultType array of objects).
+ */
+ @JsonProperty(value = "additionalColumns")
+ private List additionalColumns;
+
/**
* Get fetchXML is a proprietary query language that is used in Microsoft Common Data Service for Apps (online & on-premises). Type: string (or Expression with resultType string).
*
@@ -46,4 +54,24 @@ public CommonDataServiceForAppsSource withQuery(Object query) {
return this;
}
+ /**
+ * Get specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @return the additionalColumns value
+ */
+ public List additionalColumns() {
+ return this.additionalColumns;
+ }
+
+ /**
+ * Set specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @param additionalColumns the additionalColumns value to set
+ * @return the CommonDataServiceForAppsSource object itself.
+ */
+ public CommonDataServiceForAppsSource withAdditionalColumns(List additionalColumns) {
+ this.additionalColumns = additionalColumns;
+ return this;
+ }
+
}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CopyActivity.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CopyActivity.java
index ac73b3799217d..44418ba364bf4 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CopyActivity.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CopyActivity.java
@@ -82,6 +82,12 @@ public class CopyActivity extends ExecutionActivity {
@JsonProperty(value = "typeProperties.redirectIncompatibleRowSettings")
private RedirectIncompatibleRowSettings redirectIncompatibleRowSettings;
+ /**
+ * Log storage settings customer need to provide when enabling session log.
+ */
+ @JsonProperty(value = "typeProperties.logStorageSettings")
+ private LogStorageSettings logStorageSettings;
+
/**
* Preserve Rules.
*/
@@ -94,6 +100,19 @@ public class CopyActivity extends ExecutionActivity {
@JsonProperty(value = "typeProperties.preserve")
private List preserve;
+ /**
+ * Whether to enable Data Consistency validation. Type: boolean (or
+ * Expression with resultType boolean).
+ */
+ @JsonProperty(value = "typeProperties.validateDataConsistency")
+ private Object validateDataConsistency;
+
+ /**
+ * Specify the fault tolerance for data consistency.
+ */
+ @JsonProperty(value = "typeProperties.skipErrorFile")
+ private SkipErrorFile skipErrorFile;
+
/**
* List of inputs for the activity.
*/
@@ -286,6 +305,26 @@ public CopyActivity withRedirectIncompatibleRowSettings(RedirectIncompatibleRowS
return this;
}
+ /**
+ * Get log storage settings customer need to provide when enabling session log.
+ *
+ * @return the logStorageSettings value
+ */
+ public LogStorageSettings logStorageSettings() {
+ return this.logStorageSettings;
+ }
+
+ /**
+ * Set log storage settings customer need to provide when enabling session log.
+ *
+ * @param logStorageSettings the logStorageSettings value to set
+ * @return the CopyActivity object itself.
+ */
+ public CopyActivity withLogStorageSettings(LogStorageSettings logStorageSettings) {
+ this.logStorageSettings = logStorageSettings;
+ return this;
+ }
+
/**
* Get preserve Rules.
*
@@ -326,6 +365,46 @@ public CopyActivity withPreserve(List preserve) {
return this;
}
+ /**
+ * Get whether to enable Data Consistency validation. Type: boolean (or Expression with resultType boolean).
+ *
+ * @return the validateDataConsistency value
+ */
+ public Object validateDataConsistency() {
+ return this.validateDataConsistency;
+ }
+
+ /**
+ * Set whether to enable Data Consistency validation. Type: boolean (or Expression with resultType boolean).
+ *
+ * @param validateDataConsistency the validateDataConsistency value to set
+ * @return the CopyActivity object itself.
+ */
+ public CopyActivity withValidateDataConsistency(Object validateDataConsistency) {
+ this.validateDataConsistency = validateDataConsistency;
+ return this;
+ }
+
+ /**
+ * Get specify the fault tolerance for data consistency.
+ *
+ * @return the skipErrorFile value
+ */
+ public SkipErrorFile skipErrorFile() {
+ return this.skipErrorFile;
+ }
+
+ /**
+ * Set specify the fault tolerance for data consistency.
+ *
+ * @param skipErrorFile the skipErrorFile value to set
+ * @return the CopyActivity object itself.
+ */
+ public CopyActivity withSkipErrorFile(SkipErrorFile skipErrorFile) {
+ this.skipErrorFile = skipErrorFile;
+ return this;
+ }
+
/**
* Get list of inputs for the activity.
*
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CosmosDbMongoDbApiSource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CosmosDbMongoDbApiSource.java
index f60c7f7b2da53..10b4464feadd0 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CosmosDbMongoDbApiSource.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CosmosDbMongoDbApiSource.java
@@ -8,6 +8,7 @@
package com.microsoft.azure.management.datafactory.v2018_06_01;
+import java.util.List;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonTypeInfo;
import com.fasterxml.jackson.annotation.JsonTypeName;
@@ -49,6 +50,13 @@ public class CosmosDbMongoDbApiSource extends CopySource {
@JsonProperty(value = "queryTimeout")
private Object queryTimeout;
+ /**
+ * Specifies the additional columns to be added to source data. Type: array
+ * of objects (or Expression with resultType array of objects).
+ */
+ @JsonProperty(value = "additionalColumns")
+ private List additionalColumns;
+
/**
* Get specifies selection filter using query operators. To return all documents in a collection, omit this parameter or pass an empty document ({}). Type: string (or Expression with resultType string).
*
@@ -129,4 +137,24 @@ public CosmosDbMongoDbApiSource withQueryTimeout(Object queryTimeout) {
return this;
}
+ /**
+ * Get specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @return the additionalColumns value
+ */
+ public List additionalColumns() {
+ return this.additionalColumns;
+ }
+
+ /**
+ * Set specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @param additionalColumns the additionalColumns value to set
+ * @return the CosmosDbMongoDbApiSource object itself.
+ */
+ public CosmosDbMongoDbApiSource withAdditionalColumns(List additionalColumns) {
+ this.additionalColumns = additionalColumns;
+ return this;
+ }
+
}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CosmosDbSqlApiSource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CosmosDbSqlApiSource.java
index 0cef45b0f023e..2ea67907a6221 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CosmosDbSqlApiSource.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CosmosDbSqlApiSource.java
@@ -8,6 +8,7 @@
package com.microsoft.azure.management.datafactory.v2018_06_01;
+import java.util.List;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonTypeInfo;
import com.fasterxml.jackson.annotation.JsonTypeName;
@@ -38,6 +39,13 @@ public class CosmosDbSqlApiSource extends CopySource {
@JsonProperty(value = "preferredRegions")
private Object preferredRegions;
+ /**
+ * Specifies the additional columns to be added to source data. Type: array
+ * of objects (or Expression with resultType array of objects).
+ */
+ @JsonProperty(value = "additionalColumns")
+ private List additionalColumns;
+
/**
* Get sQL API query. Type: string (or Expression with resultType string).
*
@@ -98,4 +106,24 @@ public CosmosDbSqlApiSource withPreferredRegions(Object preferredRegions) {
return this;
}
+ /**
+ * Get specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @return the additionalColumns value
+ */
+ public List additionalColumns() {
+ return this.additionalColumns;
+ }
+
+ /**
+ * Set specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @param additionalColumns the additionalColumns value to set
+ * @return the CosmosDbSqlApiSource object itself.
+ */
+ public CosmosDbSqlApiSource withAdditionalColumns(List additionalColumns) {
+ this.additionalColumns = additionalColumns;
+ return this;
+ }
+
}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/Db2LinkedService.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/Db2LinkedService.java
index af04f80ac9967..46207c24d520e 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/Db2LinkedService.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/Db2LinkedService.java
@@ -22,28 +22,40 @@
@JsonFlatten
public class Db2LinkedService extends LinkedServiceInner {
/**
- * Server name for connection. Type: string (or Expression with resultType
+ * The connection string. It is mutually exclusive with server, database,
+ * authenticationType, userName, packageCollection and
+ * certificateCommonName property. Type: string, SecureString or
+ * AzureKeyVaultSecretReference.
+ */
+ @JsonProperty(value = "typeProperties.connectionString")
+ private Object connectionString;
+
+ /**
+ * Server name for connection. It is mutually exclusive with
+ * connectionString property. Type: string (or Expression with resultType
* string).
*/
- @JsonProperty(value = "typeProperties.server", required = true)
+ @JsonProperty(value = "typeProperties.server")
private Object server;
/**
- * Database name for connection. Type: string (or Expression with
- * resultType string).
+ * Database name for connection. It is mutually exclusive with
+ * connectionString property. Type: string (or Expression with resultType
+ * string).
*/
- @JsonProperty(value = "typeProperties.database", required = true)
+ @JsonProperty(value = "typeProperties.database")
private Object database;
/**
- * AuthenticationType to be used for connection. Possible values include:
- * 'Basic'.
+ * AuthenticationType to be used for connection. It is mutually exclusive
+ * with connectionString property. Possible values include: 'Basic'.
*/
@JsonProperty(value = "typeProperties.authenticationType")
private Db2AuthenticationType authenticationType;
/**
- * Username for authentication. Type: string (or Expression with resultType
+ * Username for authentication. It is mutually exclusive with
+ * connectionString property. Type: string (or Expression with resultType
* string).
*/
@JsonProperty(value = "typeProperties.username")
@@ -56,29 +68,52 @@ public class Db2LinkedService extends LinkedServiceInner {
private SecretBase password;
/**
- * Under where packages are created when querying database. Type: string
- * (or Expression with resultType string).
+ * Under where packages are created when querying database. It is mutually
+ * exclusive with connectionString property. Type: string (or Expression
+ * with resultType string).
*/
@JsonProperty(value = "typeProperties.packageCollection")
private Object packageCollection;
/**
- * Certificate Common Name when TLS is enabled. Type: string (or Expression
- * with resultType string).
+ * Certificate Common Name when TLS is enabled. It is mutually exclusive
+ * with connectionString property. Type: string (or Expression with
+ * resultType string).
*/
@JsonProperty(value = "typeProperties.certificateCommonName")
private Object certificateCommonName;
/**
* The encrypted credential used for authentication. Credentials are
- * encrypted using the integration runtime credential manager. Type: string
- * (or Expression with resultType string).
+ * encrypted using the integration runtime credential manager. It is
+ * mutually exclusive with connectionString property. Type: string (or
+ * Expression with resultType string).
*/
@JsonProperty(value = "typeProperties.encryptedCredential")
private Object encryptedCredential;
/**
- * Get server name for connection. Type: string (or Expression with resultType string).
+ * Get the connection string. It is mutually exclusive with server, database, authenticationType, userName, packageCollection and certificateCommonName 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 server, database, authenticationType, userName, packageCollection and certificateCommonName property. Type: string, SecureString or AzureKeyVaultSecretReference.
+ *
+ * @param connectionString the connectionString value to set
+ * @return the Db2LinkedService object itself.
+ */
+ public Db2LinkedService withConnectionString(Object connectionString) {
+ this.connectionString = connectionString;
+ return this;
+ }
+
+ /**
+ * Get server name for connection. It is mutually exclusive with connectionString property. Type: string (or Expression with resultType string).
*
* @return the server value
*/
@@ -87,7 +122,7 @@ public Object server() {
}
/**
- * Set server name for connection. Type: string (or Expression with resultType string).
+ * Set server name for connection. It is mutually exclusive with connectionString property. Type: string (or Expression with resultType string).
*
* @param server the server value to set
* @return the Db2LinkedService object itself.
@@ -98,7 +133,7 @@ public Db2LinkedService withServer(Object server) {
}
/**
- * Get database name for connection. Type: string (or Expression with resultType string).
+ * Get database name for connection. It is mutually exclusive with connectionString property. Type: string (or Expression with resultType string).
*
* @return the database value
*/
@@ -107,7 +142,7 @@ public Object database() {
}
/**
- * Set database name for connection. Type: string (or Expression with resultType string).
+ * Set database name for connection. It is mutually exclusive with connectionString property. Type: string (or Expression with resultType string).
*
* @param database the database value to set
* @return the Db2LinkedService object itself.
@@ -118,7 +153,7 @@ public Db2LinkedService withDatabase(Object database) {
}
/**
- * Get authenticationType to be used for connection. Possible values include: 'Basic'.
+ * Get authenticationType to be used for connection. It is mutually exclusive with connectionString property. Possible values include: 'Basic'.
*
* @return the authenticationType value
*/
@@ -127,7 +162,7 @@ public Db2AuthenticationType authenticationType() {
}
/**
- * Set authenticationType to be used for connection. Possible values include: 'Basic'.
+ * Set authenticationType to be used for connection. It is mutually exclusive with connectionString property. Possible values include: 'Basic'.
*
* @param authenticationType the authenticationType value to set
* @return the Db2LinkedService object itself.
@@ -138,7 +173,7 @@ public Db2LinkedService withAuthenticationType(Db2AuthenticationType authenticat
}
/**
- * Get username for authentication. Type: string (or Expression with resultType string).
+ * Get username for authentication. It is mutually exclusive with connectionString property. Type: string (or Expression with resultType string).
*
* @return the username value
*/
@@ -147,7 +182,7 @@ public Object username() {
}
/**
- * Set username for authentication. Type: string (or Expression with resultType string).
+ * Set username for authentication. It is mutually exclusive with connectionString property. Type: string (or Expression with resultType string).
*
* @param username the username value to set
* @return the Db2LinkedService object itself.
@@ -178,7 +213,7 @@ public Db2LinkedService withPassword(SecretBase password) {
}
/**
- * Get under where packages are created when querying database. Type: string (or Expression with resultType string).
+ * Get under where packages are created when querying database. It is mutually exclusive with connectionString property. Type: string (or Expression with resultType string).
*
* @return the packageCollection value
*/
@@ -187,7 +222,7 @@ public Object packageCollection() {
}
/**
- * Set under where packages are created when querying database. Type: string (or Expression with resultType string).
+ * Set under where packages are created when querying database. It is mutually exclusive with connectionString property. Type: string (or Expression with resultType string).
*
* @param packageCollection the packageCollection value to set
* @return the Db2LinkedService object itself.
@@ -198,7 +233,7 @@ public Db2LinkedService withPackageCollection(Object packageCollection) {
}
/**
- * Get certificate Common Name when TLS is enabled. Type: string (or Expression with resultType string).
+ * Get certificate Common Name when TLS is enabled. It is mutually exclusive with connectionString property. Type: string (or Expression with resultType string).
*
* @return the certificateCommonName value
*/
@@ -207,7 +242,7 @@ public Object certificateCommonName() {
}
/**
- * Set certificate Common Name when TLS is enabled. Type: string (or Expression with resultType string).
+ * Set certificate Common Name when TLS is enabled. It is mutually exclusive with connectionString property. Type: string (or Expression with resultType string).
*
* @param certificateCommonName the certificateCommonName value to set
* @return the Db2LinkedService object itself.
@@ -218,7 +253,7 @@ public Db2LinkedService withCertificateCommonName(Object certificateCommonName)
}
/**
- * Get the encrypted credential used for authentication. Credentials are encrypted using the integration runtime credential manager. Type: string (or Expression with resultType string).
+ * Get the encrypted credential used for authentication. Credentials are encrypted using the integration runtime credential manager. It is mutually exclusive with connectionString property. Type: string (or Expression with resultType string).
*
* @return the encryptedCredential value
*/
@@ -227,7 +262,7 @@ public Object encryptedCredential() {
}
/**
- * Set the encrypted credential used for authentication. Credentials are encrypted using the integration runtime credential manager. Type: string (or Expression with resultType string).
+ * Set the encrypted credential used for authentication. Credentials are encrypted using the integration runtime credential manager. It is mutually exclusive with connectionString property. Type: string (or Expression with resultType string).
*
* @param encryptedCredential the encryptedCredential value to set
* @return the Db2LinkedService object itself.
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DelimitedTextSource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DelimitedTextSource.java
index 7252346f03a3e..ae40495e173b4 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DelimitedTextSource.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DelimitedTextSource.java
@@ -8,6 +8,7 @@
package com.microsoft.azure.management.datafactory.v2018_06_01;
+import java.util.List;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonTypeInfo;
import com.fasterxml.jackson.annotation.JsonTypeName;
@@ -30,6 +31,13 @@ public class DelimitedTextSource extends CopySource {
@JsonProperty(value = "formatSettings")
private DelimitedTextReadSettings formatSettings;
+ /**
+ * Specifies the additional columns to be added to source data. Type: array
+ * of objects (or Expression with resultType array of objects).
+ */
+ @JsonProperty(value = "additionalColumns")
+ private List additionalColumns;
+
/**
* Get delimitedText store settings.
*
@@ -70,4 +78,24 @@ public DelimitedTextSource withFormatSettings(DelimitedTextReadSettings formatSe
return this;
}
+ /**
+ * Get specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @return the additionalColumns value
+ */
+ public List additionalColumns() {
+ return this.additionalColumns;
+ }
+
+ /**
+ * Set specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @param additionalColumns the additionalColumns value to set
+ * @return the DelimitedTextSource object itself.
+ */
+ public DelimitedTextSource withAdditionalColumns(List additionalColumns) {
+ this.additionalColumns = additionalColumns;
+ return this;
+ }
+
}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DocumentDbCollectionSource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DocumentDbCollectionSource.java
index 6e2ab73786ac5..a60faf25b7069 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DocumentDbCollectionSource.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DocumentDbCollectionSource.java
@@ -8,6 +8,7 @@
package com.microsoft.azure.management.datafactory.v2018_06_01;
+import java.util.List;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonTypeInfo;
import com.fasterxml.jackson.annotation.JsonTypeName;
@@ -38,6 +39,13 @@ public class DocumentDbCollectionSource extends CopySource {
@JsonProperty(value = "queryTimeout")
private Object queryTimeout;
+ /**
+ * Specifies the additional columns to be added to source data. Type: array
+ * of objects (or Expression with resultType array of objects).
+ */
+ @JsonProperty(value = "additionalColumns")
+ private List additionalColumns;
+
/**
* Get documents query. Type: string (or Expression with resultType string).
*
@@ -98,4 +106,24 @@ public DocumentDbCollectionSource withQueryTimeout(Object queryTimeout) {
return this;
}
+ /**
+ * Get specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @return the additionalColumns value
+ */
+ public List additionalColumns() {
+ return this.additionalColumns;
+ }
+
+ /**
+ * Set specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @param additionalColumns the additionalColumns value to set
+ * @return the DocumentDbCollectionSource object itself.
+ */
+ public DocumentDbCollectionSource withAdditionalColumns(List additionalColumns) {
+ this.additionalColumns = additionalColumns;
+ return this;
+ }
+
}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DynamicsCrmSource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DynamicsCrmSource.java
index e0200a56106c2..c254891479558 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DynamicsCrmSource.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DynamicsCrmSource.java
@@ -8,6 +8,7 @@
package com.microsoft.azure.management.datafactory.v2018_06_01;
+import java.util.List;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonTypeInfo;
import com.fasterxml.jackson.annotation.JsonTypeName;
@@ -26,6 +27,13 @@ public class DynamicsCrmSource extends CopySource {
@JsonProperty(value = "query")
private Object query;
+ /**
+ * Specifies the additional columns to be added to source data. Type: array
+ * of objects (or Expression with resultType array of objects).
+ */
+ @JsonProperty(value = "additionalColumns")
+ private List additionalColumns;
+
/**
* Get fetchXML is a proprietary query language that is used in Microsoft Dynamics CRM (online & on-premises). Type: string (or Expression with resultType string).
*
@@ -46,4 +54,24 @@ public DynamicsCrmSource withQuery(Object query) {
return this;
}
+ /**
+ * Get specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @return the additionalColumns value
+ */
+ public List additionalColumns() {
+ return this.additionalColumns;
+ }
+
+ /**
+ * Set specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @param additionalColumns the additionalColumns value to set
+ * @return the DynamicsCrmSource object itself.
+ */
+ public DynamicsCrmSource withAdditionalColumns(List additionalColumns) {
+ this.additionalColumns = additionalColumns;
+ return this;
+ }
+
}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DynamicsSource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DynamicsSource.java
index a1b6d189f4671..f64ce5c92100d 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DynamicsSource.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DynamicsSource.java
@@ -8,6 +8,7 @@
package com.microsoft.azure.management.datafactory.v2018_06_01;
+import java.util.List;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonTypeInfo;
import com.fasterxml.jackson.annotation.JsonTypeName;
@@ -26,6 +27,13 @@ public class DynamicsSource extends CopySource {
@JsonProperty(value = "query")
private Object query;
+ /**
+ * Specifies the additional columns to be added to source data. Type: array
+ * of objects (or Expression with resultType array of objects).
+ */
+ @JsonProperty(value = "additionalColumns")
+ private List additionalColumns;
+
/**
* Get fetchXML is a proprietary query language that is used in Microsoft Dynamics (online & on-premises). Type: string (or Expression with resultType string).
*
@@ -46,4 +54,24 @@ public DynamicsSource withQuery(Object query) {
return this;
}
+ /**
+ * Get specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @return the additionalColumns value
+ */
+ public List additionalColumns() {
+ return this.additionalColumns;
+ }
+
+ /**
+ * Set specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @param additionalColumns the additionalColumns value to set
+ * @return the DynamicsSource object itself.
+ */
+ public DynamicsSource withAdditionalColumns(List additionalColumns) {
+ this.additionalColumns = additionalColumns;
+ return this;
+ }
+
}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/FileServerReadSettings.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/FileServerReadSettings.java
index e40a4b8368d84..9a64b8e218929 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
@@ -39,6 +39,14 @@ public class FileServerReadSettings extends StoreReadSettings {
@JsonProperty(value = "wildcardFileName")
private Object wildcardFileName;
+ /**
+ * 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).
+ */
+ @JsonProperty(value = "fileListPath")
+ private Object fileListPath;
+
/**
* Indicates whether to enable partition discovery.
*/
@@ -119,6 +127,26 @@ public FileServerReadSettings withWildcardFileName(Object wildcardFileName) {
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).
+ *
+ * @return the fileListPath value
+ */
+ public Object fileListPath() {
+ return this.fileListPath;
+ }
+
+ /**
+ * Set 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).
+ *
+ * @param fileListPath the fileListPath value to set
+ * @return the FileServerReadSettings object itself.
+ */
+ public FileServerReadSettings withFileListPath(Object fileListPath) {
+ this.fileListPath = fileListPath;
+ return this;
+ }
+
/**
* Get indicates whether to enable partition discovery.
*
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/FileSystemSource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/FileSystemSource.java
index c0b555f51263f..5432926aff7c2 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/FileSystemSource.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/FileSystemSource.java
@@ -8,6 +8,7 @@
package com.microsoft.azure.management.datafactory.v2018_06_01;
+import java.util.List;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonTypeInfo;
import com.fasterxml.jackson.annotation.JsonTypeName;
@@ -25,6 +26,13 @@ public class FileSystemSource extends CopySource {
@JsonProperty(value = "recursive")
private Object recursive;
+ /**
+ * Specifies the additional columns to be added to source data. Type: array
+ * of objects (or Expression with resultType array of objects).
+ */
+ @JsonProperty(value = "additionalColumns")
+ private List additionalColumns;
+
/**
* Get if true, files under the folder path will be read recursively. Default is true. Type: boolean (or Expression with resultType boolean).
*
@@ -45,4 +53,24 @@ public FileSystemSource withRecursive(Object recursive) {
return this;
}
+ /**
+ * Get specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @return the additionalColumns value
+ */
+ public List additionalColumns() {
+ return this.additionalColumns;
+ }
+
+ /**
+ * Set specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @param additionalColumns the additionalColumns value to set
+ * @return the FileSystemSource object itself.
+ */
+ public FileSystemSource withAdditionalColumns(List additionalColumns) {
+ this.additionalColumns = additionalColumns;
+ return this;
+ }
+
}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/FtpReadSettings.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/FtpReadSettings.java
index 6d3134cbb4353..921642f9ff353 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,14 @@ public class FtpReadSettings extends StoreReadSettings {
@JsonProperty(value = "wildcardFileName")
private Object wildcardFileName;
+ /**
+ * 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).
+ */
+ @JsonProperty(value = "fileListPath")
+ private Object fileListPath;
+
/**
* Specify whether to use binary transfer mode for FTP stores.
*/
@@ -105,6 +113,26 @@ public FtpReadSettings withWildcardFileName(Object wildcardFileName) {
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).
+ *
+ * @return the fileListPath value
+ */
+ public Object fileListPath() {
+ return this.fileListPath;
+ }
+
+ /**
+ * Set 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).
+ *
+ * @param fileListPath the fileListPath value to set
+ * @return the FtpReadSettings object itself.
+ */
+ public FtpReadSettings withFileListPath(Object fileListPath) {
+ this.fileListPath = fileListPath;
+ return this;
+ }
+
/**
* Get specify whether to use binary transfer mode for FTP stores.
*
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 3a3c52b2a0fcc..c6368a06345f3 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
@@ -46,6 +46,14 @@ public class GoogleCloudStorageReadSettings extends StoreReadSettings {
@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
+ * Expression with resultType string).
+ */
+ @JsonProperty(value = "fileListPath")
+ private Object fileListPath;
+
/**
* Indicates whether to enable partition discovery.
*/
@@ -146,6 +154,26 @@ public GoogleCloudStorageReadSettings withPrefix(Object 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).
+ *
+ * @return the fileListPath value
+ */
+ public Object fileListPath() {
+ return this.fileListPath;
+ }
+
+ /**
+ * Set 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).
+ *
+ * @param fileListPath the fileListPath value to set
+ * @return the GoogleCloudStorageReadSettings object itself.
+ */
+ public GoogleCloudStorageReadSettings withFileListPath(Object fileListPath) {
+ this.fileListPath = fileListPath;
+ return this;
+ }
+
/**
* Get indicates whether to enable partition discovery.
*
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 ebec4eaf84561..6915c721c2da3 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
@@ -39,6 +39,14 @@ public class HdfsReadSettings extends StoreReadSettings {
@JsonProperty(value = "wildcardFileName")
private Object wildcardFileName;
+ /**
+ * 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).
+ */
+ @JsonProperty(value = "fileListPath")
+ private Object fileListPath;
+
/**
* Indicates whether to enable partition discovery.
*/
@@ -125,6 +133,26 @@ public HdfsReadSettings withWildcardFileName(Object wildcardFileName) {
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).
+ *
+ * @return the fileListPath value
+ */
+ public Object fileListPath() {
+ return this.fileListPath;
+ }
+
+ /**
+ * Set 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).
+ *
+ * @param fileListPath the fileListPath value to set
+ * @return the HdfsReadSettings object itself.
+ */
+ public HdfsReadSettings withFileListPath(Object fileListPath) {
+ this.fileListPath = fileListPath;
+ return this;
+ }
+
/**
* Get indicates whether to enable partition discovery.
*
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 d1a0d952696f5..84a3eb79a72f1 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
@@ -8,6 +8,7 @@
package com.microsoft.azure.management.datafactory.v2018_06_01;
+import java.util.List;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonTypeInfo;
import com.fasterxml.jackson.annotation.JsonTypeName;
@@ -24,6 +25,13 @@ public class JsonSource extends CopySource {
@JsonProperty(value = "storeSettings")
private StoreReadSettings storeSettings;
+ /**
+ * Specifies the additional columns to be added to source data. Type: array
+ * of objects (or Expression with resultType array of objects).
+ */
+ @JsonProperty(value = "additionalColumns")
+ private List additionalColumns;
+
/**
* Get json store settings.
*
@@ -44,4 +52,24 @@ public JsonSource withStoreSettings(StoreReadSettings storeSettings) {
return this;
}
+ /**
+ * Get specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @return the additionalColumns value
+ */
+ public List additionalColumns() {
+ return this.additionalColumns;
+ }
+
+ /**
+ * Set specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @param additionalColumns the additionalColumns value to set
+ * @return the JsonSource object itself.
+ */
+ public JsonSource withAdditionalColumns(List additionalColumns) {
+ this.additionalColumns = additionalColumns;
+ return this;
+ }
+
}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/MicrosoftAccessSource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/MicrosoftAccessSource.java
index 7ad024288e490..3b589d53c30aa 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/MicrosoftAccessSource.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/MicrosoftAccessSource.java
@@ -8,6 +8,7 @@
package com.microsoft.azure.management.datafactory.v2018_06_01;
+import java.util.List;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonTypeInfo;
import com.fasterxml.jackson.annotation.JsonTypeName;
@@ -24,6 +25,13 @@ public class MicrosoftAccessSource extends CopySource {
@JsonProperty(value = "query")
private Object query;
+ /**
+ * Specifies the additional columns to be added to source data. Type: array
+ * of objects (or Expression with resultType array of objects).
+ */
+ @JsonProperty(value = "additionalColumns")
+ private List additionalColumns;
+
/**
* Get database query. Type: string (or Expression with resultType string).
*
@@ -44,4 +52,24 @@ public MicrosoftAccessSource withQuery(Object query) {
return this;
}
+ /**
+ * Get specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @return the additionalColumns value
+ */
+ public List additionalColumns() {
+ return this.additionalColumns;
+ }
+
+ /**
+ * Set specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @param additionalColumns the additionalColumns value to set
+ * @return the MicrosoftAccessSource object itself.
+ */
+ public MicrosoftAccessSource withAdditionalColumns(List additionalColumns) {
+ this.additionalColumns = additionalColumns;
+ return this;
+ }
+
}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/MongoDbSource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/MongoDbSource.java
index b3bdde338853d..fe15e0f0a861c 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/MongoDbSource.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/MongoDbSource.java
@@ -8,6 +8,7 @@
package com.microsoft.azure.management.datafactory.v2018_06_01;
+import java.util.List;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonTypeInfo;
import com.fasterxml.jackson.annotation.JsonTypeName;
@@ -25,6 +26,13 @@ public class MongoDbSource extends CopySource {
@JsonProperty(value = "query")
private Object query;
+ /**
+ * Specifies the additional columns to be added to source data. Type: array
+ * of objects (or Expression with resultType array of objects).
+ */
+ @JsonProperty(value = "additionalColumns")
+ private List additionalColumns;
+
/**
* Get database query. Should be a SQL-92 query expression. Type: string (or Expression with resultType string).
*
@@ -45,4 +53,24 @@ public MongoDbSource withQuery(Object query) {
return this;
}
+ /**
+ * Get specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @return the additionalColumns value
+ */
+ public List additionalColumns() {
+ return this.additionalColumns;
+ }
+
+ /**
+ * Set specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @param additionalColumns the additionalColumns value to set
+ * @return the MongoDbSource object itself.
+ */
+ public MongoDbSource withAdditionalColumns(List additionalColumns) {
+ this.additionalColumns = additionalColumns;
+ return this;
+ }
+
}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/MongoDbV2Source.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/MongoDbV2Source.java
index a72165e1fe3cc..df00d36c8c85d 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/MongoDbV2Source.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/MongoDbV2Source.java
@@ -8,6 +8,7 @@
package com.microsoft.azure.management.datafactory.v2018_06_01;
+import java.util.List;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonTypeInfo;
import com.fasterxml.jackson.annotation.JsonTypeName;
@@ -49,6 +50,13 @@ public class MongoDbV2Source extends CopySource {
@JsonProperty(value = "queryTimeout")
private Object queryTimeout;
+ /**
+ * Specifies the additional columns to be added to source data. Type: array
+ * of objects (or Expression with resultType array of objects).
+ */
+ @JsonProperty(value = "additionalColumns")
+ private List additionalColumns;
+
/**
* Get specifies selection filter using query operators. To return all documents in a collection, omit this parameter or pass an empty document ({}). Type: string (or Expression with resultType string).
*
@@ -129,4 +137,24 @@ public MongoDbV2Source withQueryTimeout(Object queryTimeout) {
return this;
}
+ /**
+ * Get specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @return the additionalColumns value
+ */
+ public List additionalColumns() {
+ return this.additionalColumns;
+ }
+
+ /**
+ * Set specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @param additionalColumns the additionalColumns value to set
+ * @return the MongoDbV2Source object itself.
+ */
+ public MongoDbV2Source withAdditionalColumns(List additionalColumns) {
+ this.additionalColumns = additionalColumns;
+ return this;
+ }
+
}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/ODataSource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/ODataSource.java
index 531108fb8e7b9..57c3fae095737 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
@@ -8,6 +8,7 @@
package com.microsoft.azure.management.datafactory.v2018_06_01;
+import java.util.List;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonTypeInfo;
import com.fasterxml.jackson.annotation.JsonTypeName;
@@ -25,6 +26,13 @@ public class ODataSource extends CopySource {
@JsonProperty(value = "query")
private Object query;
+ /**
+ * Specifies the additional columns to be added to source data. Type: array
+ * of objects (or Expression with resultType array of objects).
+ */
+ @JsonProperty(value = "additionalColumns")
+ private List additionalColumns;
+
/**
* Get oData query. For example, "$top=1". Type: string (or Expression with resultType string).
*
@@ -45,4 +53,24 @@ public ODataSource withQuery(Object query) {
return this;
}
+ /**
+ * Get specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @return the additionalColumns value
+ */
+ public List additionalColumns() {
+ return this.additionalColumns;
+ }
+
+ /**
+ * Set specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @param additionalColumns the additionalColumns value to set
+ * @return the ODataSource object itself.
+ */
+ public ODataSource withAdditionalColumns(List additionalColumns) {
+ this.additionalColumns = additionalColumns;
+ return this;
+ }
+
}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/OracleSource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/OracleSource.java
index 05e8227cd8c70..9995a54f83591 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/OracleSource.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/OracleSource.java
@@ -8,6 +8,7 @@
package com.microsoft.azure.management.datafactory.v2018_06_01;
+import java.util.List;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonTypeInfo;
import com.fasterxml.jackson.annotation.JsonTypeName;
@@ -46,6 +47,13 @@ public class OracleSource extends CopySource {
@JsonProperty(value = "partitionSettings")
private OraclePartitionSettings partitionSettings;
+ /**
+ * Specifies the additional columns to be added to source data. Type: array
+ * of objects (or Expression with resultType array of objects).
+ */
+ @JsonProperty(value = "additionalColumns")
+ private List additionalColumns;
+
/**
* Get oracle reader query. Type: string (or Expression with resultType string).
*
@@ -126,4 +134,24 @@ public OracleSource withPartitionSettings(OraclePartitionSettings partitionSetti
return this;
}
+ /**
+ * Get specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @return the additionalColumns value
+ */
+ public List additionalColumns() {
+ return this.additionalColumns;
+ }
+
+ /**
+ * Set specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @param additionalColumns the additionalColumns value to set
+ * @return the OracleSource object itself.
+ */
+ public OracleSource withAdditionalColumns(List additionalColumns) {
+ this.additionalColumns = additionalColumns;
+ return this;
+ }
+
}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/OrcSource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/OrcSource.java
index d36bdf66c3beb..b477c20e7378f 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/OrcSource.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/OrcSource.java
@@ -8,6 +8,7 @@
package com.microsoft.azure.management.datafactory.v2018_06_01;
+import java.util.List;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonTypeInfo;
import com.fasterxml.jackson.annotation.JsonTypeName;
@@ -24,6 +25,13 @@ public class OrcSource extends CopySource {
@JsonProperty(value = "storeSettings")
private StoreReadSettings storeSettings;
+ /**
+ * Specifies the additional columns to be added to source data. Type: array
+ * of objects (or Expression with resultType array of objects).
+ */
+ @JsonProperty(value = "additionalColumns")
+ private List additionalColumns;
+
/**
* Get oRC store settings.
*
@@ -44,4 +52,24 @@ public OrcSource withStoreSettings(StoreReadSettings storeSettings) {
return this;
}
+ /**
+ * Get specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @return the additionalColumns value
+ */
+ public List additionalColumns() {
+ return this.additionalColumns;
+ }
+
+ /**
+ * Set specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @param additionalColumns the additionalColumns value to set
+ * @return the OrcSource object itself.
+ */
+ public OrcSource withAdditionalColumns(List additionalColumns) {
+ this.additionalColumns = additionalColumns;
+ return this;
+ }
+
}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/ParquetSource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/ParquetSource.java
index 1b45484ef922b..af26ea794f5b3 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/ParquetSource.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/ParquetSource.java
@@ -8,6 +8,7 @@
package com.microsoft.azure.management.datafactory.v2018_06_01;
+import java.util.List;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonTypeInfo;
import com.fasterxml.jackson.annotation.JsonTypeName;
@@ -24,6 +25,13 @@ public class ParquetSource extends CopySource {
@JsonProperty(value = "storeSettings")
private StoreReadSettings storeSettings;
+ /**
+ * Specifies the additional columns to be added to source data. Type: array
+ * of objects (or Expression with resultType array of objects).
+ */
+ @JsonProperty(value = "additionalColumns")
+ private List additionalColumns;
+
/**
* Get parquet store settings.
*
@@ -44,4 +52,24 @@ public ParquetSource withStoreSettings(StoreReadSettings storeSettings) {
return this;
}
+ /**
+ * Get specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @return the additionalColumns value
+ */
+ public List additionalColumns() {
+ return this.additionalColumns;
+ }
+
+ /**
+ * Set specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @param additionalColumns the additionalColumns value to set
+ * @return the ParquetSource object itself.
+ */
+ public ParquetSource withAdditionalColumns(List additionalColumns) {
+ this.additionalColumns = additionalColumns;
+ return this;
+ }
+
}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/RelationalSource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/RelationalSource.java
index afb7e16594e95..e74717ddd1a9a 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/RelationalSource.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/RelationalSource.java
@@ -8,6 +8,7 @@
package com.microsoft.azure.management.datafactory.v2018_06_01;
+import java.util.List;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonTypeInfo;
import com.fasterxml.jackson.annotation.JsonTypeName;
@@ -24,6 +25,13 @@ public class RelationalSource extends CopySource {
@JsonProperty(value = "query")
private Object query;
+ /**
+ * Specifies the additional columns to be added to source data. Type: array
+ * of objects (or Expression with resultType array of objects).
+ */
+ @JsonProperty(value = "additionalColumns")
+ private List additionalColumns;
+
/**
* Get database query. Type: string (or Expression with resultType string).
*
@@ -44,4 +52,24 @@ public RelationalSource withQuery(Object query) {
return this;
}
+ /**
+ * Get specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @return the additionalColumns value
+ */
+ public List additionalColumns() {
+ return this.additionalColumns;
+ }
+
+ /**
+ * Set specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @param additionalColumns the additionalColumns value to set
+ * @return the RelationalSource object itself.
+ */
+ public RelationalSource withAdditionalColumns(List additionalColumns) {
+ this.additionalColumns = additionalColumns;
+ return this;
+ }
+
}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/RestSource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/RestSource.java
index 45adc7476bd1b..49cd582d68fa1 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/RestSource.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/RestSource.java
@@ -8,6 +8,7 @@
package com.microsoft.azure.management.datafactory.v2018_06_01;
+import java.util.List;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonTypeInfo;
import com.fasterxml.jackson.annotation.JsonTypeName;
@@ -61,6 +62,13 @@ public class RestSource extends CopySource {
@JsonProperty(value = "requestInterval")
private Object requestInterval;
+ /**
+ * Specifies the additional columns to be added to source data. Type: array
+ * of objects (or Expression with resultType array of objects).
+ */
+ @JsonProperty(value = "additionalColumns")
+ private List additionalColumns;
+
/**
* Get the HTTP method used to call the RESTful API. The default is GET. Type: string (or Expression with resultType string).
*
@@ -181,4 +189,24 @@ public RestSource withRequestInterval(Object requestInterval) {
return this;
}
+ /**
+ * Get specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @return the additionalColumns value
+ */
+ public List additionalColumns() {
+ return this.additionalColumns;
+ }
+
+ /**
+ * Set specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @param additionalColumns the additionalColumns value to set
+ * @return the RestSource object itself.
+ */
+ public RestSource withAdditionalColumns(List additionalColumns) {
+ this.additionalColumns = additionalColumns;
+ return this;
+ }
+
}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SalesforceLinkedService.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SalesforceLinkedService.java
index 28d2e47bcccae..c4576dd923cb9 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SalesforceLinkedService.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SalesforceLinkedService.java
@@ -45,11 +45,18 @@ public class SalesforceLinkedService extends LinkedServiceInner {
private SecretBase password;
/**
- * The security token is required to remotely access Salesforce instance.
+ * The security token is optional to remotely access Salesforce instance.
*/
@JsonProperty(value = "typeProperties.securityToken")
private SecretBase securityToken;
+ /**
+ * The Salesforce API version used in ADF. Type: string (or Expression with
+ * resultType string).
+ */
+ @JsonProperty(value = "typeProperties.apiVersion")
+ private Object apiVersion;
+
/**
* The encrypted credential used for authentication. Credentials are
* encrypted using the integration runtime credential manager. Type: string
@@ -119,7 +126,7 @@ public SalesforceLinkedService withPassword(SecretBase password) {
}
/**
- * Get the security token is required to remotely access Salesforce instance.
+ * Get the security token is optional to remotely access Salesforce instance.
*
* @return the securityToken value
*/
@@ -128,7 +135,7 @@ public SecretBase securityToken() {
}
/**
- * Set the security token is required to remotely access Salesforce instance.
+ * Set the security token is optional to remotely access Salesforce instance.
*
* @param securityToken the securityToken value to set
* @return the SalesforceLinkedService object itself.
@@ -138,6 +145,26 @@ public SalesforceLinkedService withSecurityToken(SecretBase securityToken) {
return this;
}
+ /**
+ * Get the Salesforce API version used in ADF. Type: string (or Expression with resultType string).
+ *
+ * @return the apiVersion value
+ */
+ public Object apiVersion() {
+ return this.apiVersion;
+ }
+
+ /**
+ * Set the Salesforce API version used in ADF. Type: string (or Expression with resultType string).
+ *
+ * @param apiVersion the apiVersion value to set
+ * @return the SalesforceLinkedService object itself.
+ */
+ public SalesforceLinkedService withApiVersion(Object apiVersion) {
+ this.apiVersion = apiVersion;
+ 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/SalesforceServiceCloudLinkedService.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SalesforceServiceCloudLinkedService.java
index 988f41ecbcff0..2292eade7e8b4 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SalesforceServiceCloudLinkedService.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SalesforceServiceCloudLinkedService.java
@@ -45,11 +45,18 @@ public class SalesforceServiceCloudLinkedService extends LinkedServiceInner {
private SecretBase password;
/**
- * The security token is required to remotely access Salesforce instance.
+ * The security token is optional to remotely access Salesforce instance.
*/
@JsonProperty(value = "typeProperties.securityToken")
private SecretBase securityToken;
+ /**
+ * The Salesforce API version used in ADF. Type: string (or Expression with
+ * resultType string).
+ */
+ @JsonProperty(value = "typeProperties.apiVersion")
+ private Object apiVersion;
+
/**
* Extended properties appended to the connection string. Type: string (or
* Expression with resultType string).
@@ -126,7 +133,7 @@ public SalesforceServiceCloudLinkedService withPassword(SecretBase password) {
}
/**
- * Get the security token is required to remotely access Salesforce instance.
+ * Get the security token is optional to remotely access Salesforce instance.
*
* @return the securityToken value
*/
@@ -135,7 +142,7 @@ public SecretBase securityToken() {
}
/**
- * Set the security token is required to remotely access Salesforce instance.
+ * Set the security token is optional to remotely access Salesforce instance.
*
* @param securityToken the securityToken value to set
* @return the SalesforceServiceCloudLinkedService object itself.
@@ -145,6 +152,26 @@ public SalesforceServiceCloudLinkedService withSecurityToken(SecretBase security
return this;
}
+ /**
+ * Get the Salesforce API version used in ADF. Type: string (or Expression with resultType string).
+ *
+ * @return the apiVersion value
+ */
+ public Object apiVersion() {
+ return this.apiVersion;
+ }
+
+ /**
+ * Set the Salesforce API version used in ADF. Type: string (or Expression with resultType string).
+ *
+ * @param apiVersion the apiVersion value to set
+ * @return the SalesforceServiceCloudLinkedService object itself.
+ */
+ public SalesforceServiceCloudLinkedService withApiVersion(Object apiVersion) {
+ this.apiVersion = apiVersion;
+ return this;
+ }
+
/**
* Get extended properties appended to the connection string. 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/SalesforceServiceCloudSource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SalesforceServiceCloudSource.java
index 2c7bc57dd00cf..cef81b8553795 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SalesforceServiceCloudSource.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SalesforceServiceCloudSource.java
@@ -8,6 +8,7 @@
package com.microsoft.azure.management.datafactory.v2018_06_01;
+import java.util.List;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonTypeInfo;
import com.fasterxml.jackson.annotation.JsonTypeName;
@@ -31,6 +32,13 @@ public class SalesforceServiceCloudSource extends CopySource {
@JsonProperty(value = "readBehavior")
private SalesforceSourceReadBehavior readBehavior;
+ /**
+ * Specifies the additional columns to be added to source data. Type: array
+ * of objects (or Expression with resultType array of objects).
+ */
+ @JsonProperty(value = "additionalColumns")
+ private List additionalColumns;
+
/**
* Get database query. Type: string (or Expression with resultType string).
*
@@ -71,4 +79,24 @@ public SalesforceServiceCloudSource withReadBehavior(SalesforceSourceReadBehavio
return this;
}
+ /**
+ * Get specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @return the additionalColumns value
+ */
+ public List additionalColumns() {
+ return this.additionalColumns;
+ }
+
+ /**
+ * Set specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @param additionalColumns the additionalColumns value to set
+ * @return the SalesforceServiceCloudSource object itself.
+ */
+ public SalesforceServiceCloudSource withAdditionalColumns(List additionalColumns) {
+ this.additionalColumns = additionalColumns;
+ return this;
+ }
+
}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SftpReadSettings.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SftpReadSettings.java
index 4c50a8c45cfb1..c8e3012479407 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,14 @@ public class SftpReadSettings extends StoreReadSettings {
@JsonProperty(value = "wildcardFileName")
private Object wildcardFileName;
+ /**
+ * 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).
+ */
+ @JsonProperty(value = "fileListPath")
+ private Object fileListPath;
+
/**
* The start of file's modified datetime. Type: string (or Expression with
* resultType string).
@@ -113,6 +121,26 @@ public SftpReadSettings withWildcardFileName(Object wildcardFileName) {
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).
+ *
+ * @return the fileListPath value
+ */
+ public Object fileListPath() {
+ return this.fileListPath;
+ }
+
+ /**
+ * Set 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).
+ *
+ * @param fileListPath the fileListPath value to set
+ * @return the SftpReadSettings object itself.
+ */
+ public SftpReadSettings withFileListPath(Object fileListPath) {
+ this.fileListPath = fileListPath;
+ 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/SftpWriteSettings.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SftpWriteSettings.java
index 3bab9e6370cc1..b868047998cb7 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SftpWriteSettings.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SftpWriteSettings.java
@@ -26,6 +26,14 @@ public class SftpWriteSettings extends StoreWriteSettings {
@JsonProperty(value = "operationTimeout")
private Object operationTimeout;
+ /**
+ * Upload to temporary file(s) and rename. Disable this option if your SFTP
+ * server doesn't support rename operation. Type: boolean (or Expression
+ * with resultType boolean).
+ */
+ @JsonProperty(value = "useTempFileRename")
+ private Object useTempFileRename;
+
/**
* Get specifies the timeout for writing each chunk to SFTP server. Default value: 01:00:00 (one hour). Type: string (or Expression with resultType string).
*
@@ -46,4 +54,24 @@ public SftpWriteSettings withOperationTimeout(Object operationTimeout) {
return this;
}
+ /**
+ * Get upload to temporary file(s) and rename. Disable this option if your SFTP server doesn't support rename operation. Type: boolean (or Expression with resultType boolean).
+ *
+ * @return the useTempFileRename value
+ */
+ public Object useTempFileRename() {
+ return this.useTempFileRename;
+ }
+
+ /**
+ * Set upload to temporary file(s) and rename. Disable this option if your SFTP server doesn't support rename operation. Type: boolean (or Expression with resultType boolean).
+ *
+ * @param useTempFileRename the useTempFileRename value to set
+ * @return the SftpWriteSettings object itself.
+ */
+ public SftpWriteSettings withUseTempFileRename(Object useTempFileRename) {
+ this.useTempFileRename = useTempFileRename;
+ return this;
+ }
+
}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SkipErrorFile.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SkipErrorFile.java
new file mode 100644
index 0000000000000..830a992f26fd2
--- /dev/null
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SkipErrorFile.java
@@ -0,0 +1,71 @@
+/**
+ * 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;
+
+/**
+ * Skip error file.
+ */
+public class SkipErrorFile {
+ /**
+ * Skip if file is deleted by other client during copy. Default is true.
+ * Type: boolean (or Expression with resultType boolean).
+ */
+ @JsonProperty(value = "fileMissing")
+ private Object fileMissing;
+
+ /**
+ * Skip if source/sink file changed by other concurrent write. Default is
+ * false. Type: boolean (or Expression with resultType boolean).
+ */
+ @JsonProperty(value = "dataInconsistency")
+ private Object dataInconsistency;
+
+ /**
+ * Get skip if file is deleted by other client during copy. Default is true. Type: boolean (or Expression with resultType boolean).
+ *
+ * @return the fileMissing value
+ */
+ public Object fileMissing() {
+ return this.fileMissing;
+ }
+
+ /**
+ * Set skip if file is deleted by other client during copy. Default is true. Type: boolean (or Expression with resultType boolean).
+ *
+ * @param fileMissing the fileMissing value to set
+ * @return the SkipErrorFile object itself.
+ */
+ public SkipErrorFile withFileMissing(Object fileMissing) {
+ this.fileMissing = fileMissing;
+ return this;
+ }
+
+ /**
+ * Get skip if source/sink file changed by other concurrent write. Default is false. Type: boolean (or Expression with resultType boolean).
+ *
+ * @return the dataInconsistency value
+ */
+ public Object dataInconsistency() {
+ return this.dataInconsistency;
+ }
+
+ /**
+ * Set skip if source/sink file changed by other concurrent write. Default is false. Type: boolean (or Expression with resultType boolean).
+ *
+ * @param dataInconsistency the dataInconsistency value to set
+ * @return the SkipErrorFile object itself.
+ */
+ public SkipErrorFile withDataInconsistency(Object dataInconsistency) {
+ this.dataInconsistency = dataInconsistency;
+ 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 1f634e2fea2db..771a81b9058f4 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
@@ -40,6 +40,16 @@ public class SqlSource extends TabularSource {
@JsonProperty(value = "storedProcedureParameters")
private Map storedProcedureParameters;
+ /**
+ * Specifies the transaction locking behavior for the SQL source. Allowed
+ * values:
+ * ReadCommitted/ReadUncommitted/RepeatableRead/Serializable/Snapshot. The
+ * default value is ReadCommitted. Type: string (or Expression with
+ * resultType string).
+ */
+ @JsonProperty(value = "isolationLevel")
+ private Object isolationLevel;
+
/**
* Get sQL reader query. Type: string (or Expression with resultType string).
*
@@ -100,4 +110,24 @@ public SqlSource withStoredProcedureParameters(Map additionalColumns;
+
/**
* Get query timeout. Type: string (or Expression with resultType string), pattern: ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
*
@@ -105,4 +113,24 @@ public TabularSource withQueryTimeout(Object queryTimeout) {
return this;
}
+ /**
+ * Get specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @return the additionalColumns value
+ */
+ public List additionalColumns() {
+ return this.additionalColumns;
+ }
+
+ /**
+ * Set specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @param additionalColumns the additionalColumns value to set
+ * @return the TabularSource object itself.
+ */
+ public TabularSource withAdditionalColumns(List additionalColumns) {
+ this.additionalColumns = additionalColumns;
+ return this;
+ }
+
}
diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/WebSource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/WebSource.java
index be1b71834eaf6..a73791457904f 100644
--- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/WebSource.java
+++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/WebSource.java
@@ -8,6 +8,8 @@
package com.microsoft.azure.management.datafactory.v2018_06_01;
+import java.util.List;
+import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonTypeInfo;
import com.fasterxml.jackson.annotation.JsonTypeName;
@@ -17,4 +19,31 @@
@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type", defaultImpl = WebSource.class)
@JsonTypeName("WebSource")
public class WebSource extends CopySource {
+ /**
+ * Specifies the additional columns to be added to source data. Type: array
+ * of objects (or Expression with resultType array of objects).
+ */
+ @JsonProperty(value = "additionalColumns")
+ private List additionalColumns;
+
+ /**
+ * Get specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @return the additionalColumns value
+ */
+ public List additionalColumns() {
+ return this.additionalColumns;
+ }
+
+ /**
+ * Set specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects).
+ *
+ * @param additionalColumns the additionalColumns value to set
+ * @return the WebSource object itself.
+ */
+ public WebSource withAdditionalColumns(List additionalColumns) {
+ this.additionalColumns = additionalColumns;
+ return this;
+ }
+
}