diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/AzureDatabricksLinkedService.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/AzureDatabricksLinkedService.cs
index 1ac3e9ad74f8..76f63b301128 100644
--- a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/AzureDatabricksLinkedService.cs
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/AzureDatabricksLinkedService.cs
@@ -83,6 +83,9 @@ public AzureDatabricksLinkedService()
         /// <param name="newClusterCustomTags">Additional tags for cluster
         /// resources. This property is ignored in instance pool
         /// configurations.</param>
+        /// <param name="newClusterLogDestination">Specify a location to
+        /// deliver Spark driver, worker, and event logs. Type: string (or
+        /// Expression with resultType string).</param>
         /// <param name="newClusterDriverNodeType">The driver node type for the
         /// new job cluster. This property is ignored in instance pool
         /// configurations. Type: string (or Expression with resultType
@@ -99,7 +102,7 @@ public AzureDatabricksLinkedService()
         /// authentication. Credentials are encrypted using the integration
         /// runtime credential manager. Type: string (or Expression with
         /// resultType string).</param>
-        public AzureDatabricksLinkedService(object domain, SecretBase accessToken, IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), IntegrationRuntimeReference connectVia = default(IntegrationRuntimeReference), string description = default(string), IDictionary<string, ParameterSpecification> parameters = default(IDictionary<string, ParameterSpecification>), IList<object> annotations = default(IList<object>), object existingClusterId = default(object), object instancePoolId = default(object), object newClusterVersion = default(object), object newClusterNumOfWorker = default(object), object newClusterNodeType = default(object), IDictionary<string, object> newClusterSparkConf = default(IDictionary<string, object>), IDictionary<string, object> newClusterSparkEnvVars = default(IDictionary<string, object>), IDictionary<string, object> newClusterCustomTags = default(IDictionary<string, object>), object newClusterDriverNodeType = default(object), object newClusterInitScripts = default(object), object newClusterEnableElasticDisk = default(object), object encryptedCredential = default(object))
+        public AzureDatabricksLinkedService(object domain, SecretBase accessToken, IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), IntegrationRuntimeReference connectVia = default(IntegrationRuntimeReference), string description = default(string), IDictionary<string, ParameterSpecification> parameters = default(IDictionary<string, ParameterSpecification>), IList<object> annotations = default(IList<object>), object existingClusterId = default(object), object instancePoolId = default(object), object newClusterVersion = default(object), object newClusterNumOfWorker = default(object), object newClusterNodeType = default(object), IDictionary<string, object> newClusterSparkConf = default(IDictionary<string, object>), IDictionary<string, object> newClusterSparkEnvVars = default(IDictionary<string, object>), IDictionary<string, object> newClusterCustomTags = default(IDictionary<string, object>), object newClusterLogDestination = default(object), object newClusterDriverNodeType = default(object), object newClusterInitScripts = default(object), object newClusterEnableElasticDisk = default(object), object encryptedCredential = default(object))
             : base(additionalProperties, connectVia, description, parameters, annotations)
         {
             Domain = domain;
@@ -112,6 +115,7 @@ public AzureDatabricksLinkedService()
             NewClusterSparkConf = newClusterSparkConf;
             NewClusterSparkEnvVars = newClusterSparkEnvVars;
             NewClusterCustomTags = newClusterCustomTags;
+            NewClusterLogDestination = newClusterLogDestination;
             NewClusterDriverNodeType = newClusterDriverNodeType;
             NewClusterInitScripts = newClusterInitScripts;
             NewClusterEnableElasticDisk = newClusterEnableElasticDisk;
@@ -209,6 +213,14 @@ public AzureDatabricksLinkedService()
         [JsonProperty(PropertyName = "typeProperties.newClusterCustomTags")]
         public IDictionary<string, object> NewClusterCustomTags { get; set; }
 
+        /// <summary>
+        /// Gets or sets specify a location to deliver Spark driver, worker,
+        /// and event logs. Type: string (or Expression with resultType
+        /// string).
+        /// </summary>
+        [JsonProperty(PropertyName = "typeProperties.newClusterLogDestination")]
+        public object NewClusterLogDestination { get; set; }
+
         /// <summary>
         /// Gets or sets the driver node type for the new job cluster. This
         /// property is ignored in instance pool configurations. Type: string
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/AzureSqlSource.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/AzureSqlSource.cs
index 7efd3dd7e98a..f0f16e36471c 100644
--- a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/AzureSqlSource.cs
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/AzureSqlSource.cs
@@ -58,13 +58,20 @@ public AzureSqlSource()
         /// type: "int"}}".</param>
         /// <param name="produceAdditionalTypes">Which additional types to
         /// produce.</param>
-        public AzureSqlSource(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object sourceRetryCount = default(object), object sourceRetryWait = default(object), object maxConcurrentConnections = default(object), object queryTimeout = default(object), IList<AdditionalColumns> additionalColumns = default(IList<AdditionalColumns>), object sqlReaderQuery = default(object), object sqlReaderStoredProcedureName = default(object), IDictionary<string, StoredProcedureParameter> storedProcedureParameters = default(IDictionary<string, StoredProcedureParameter>), object produceAdditionalTypes = default(object))
+        /// <param name="partitionOption">The partition mechanism that will be
+        /// used for Sql read in parallel. Possible values include: 'None',
+        /// 'PhysicalPartitionsOfTable', 'DynamicRange'</param>
+        /// <param name="partitionSettings">The settings that will be leveraged
+        /// for Sql source partitioning.</param>
+        public AzureSqlSource(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object sourceRetryCount = default(object), object sourceRetryWait = default(object), object maxConcurrentConnections = default(object), object queryTimeout = default(object), IList<AdditionalColumns> additionalColumns = default(IList<AdditionalColumns>), object sqlReaderQuery = default(object), object sqlReaderStoredProcedureName = default(object), IDictionary<string, StoredProcedureParameter> storedProcedureParameters = default(IDictionary<string, StoredProcedureParameter>), object produceAdditionalTypes = default(object), string partitionOption = default(string), SqlPartitionSettings partitionSettings = default(SqlPartitionSettings))
             : base(additionalProperties, sourceRetryCount, sourceRetryWait, maxConcurrentConnections, queryTimeout, additionalColumns)
         {
             SqlReaderQuery = sqlReaderQuery;
             SqlReaderStoredProcedureName = sqlReaderStoredProcedureName;
             StoredProcedureParameters = storedProcedureParameters;
             ProduceAdditionalTypes = produceAdditionalTypes;
+            PartitionOption = partitionOption;
+            PartitionSettings = partitionSettings;
             CustomInit();
         }
 
@@ -101,5 +108,20 @@ public AzureSqlSource()
         [JsonProperty(PropertyName = "produceAdditionalTypes")]
         public object ProduceAdditionalTypes { get; set; }
 
+        /// <summary>
+        /// Gets or sets the partition mechanism that will be used for Sql read
+        /// in parallel. Possible values include: 'None',
+        /// 'PhysicalPartitionsOfTable', 'DynamicRange'
+        /// </summary>
+        [JsonProperty(PropertyName = "partitionOption")]
+        public string PartitionOption { get; set; }
+
+        /// <summary>
+        /// Gets or sets the settings that will be leveraged for Sql source
+        /// partitioning.
+        /// </summary>
+        [JsonProperty(PropertyName = "partitionSettings")]
+        public SqlPartitionSettings PartitionSettings { get; set; }
+
     }
 }
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/DataFlowStagingInfo.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/DataFlowStagingInfo.cs
index b77877ea33a0..67e7c7e5fd5d 100644
--- a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/DataFlowStagingInfo.cs
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/DataFlowStagingInfo.cs
@@ -31,8 +31,9 @@ public DataFlowStagingInfo()
         /// </summary>
         /// <param name="linkedService">Staging linked service
         /// reference.</param>
-        /// <param name="folderPath">Folder path for staging blob.</param>
-        public DataFlowStagingInfo(LinkedServiceReference linkedService = default(LinkedServiceReference), string folderPath = default(string))
+        /// <param name="folderPath">Folder path for staging blob. Type: string
+        /// (or Expression with resultType string)</param>
+        public DataFlowStagingInfo(LinkedServiceReference linkedService = default(LinkedServiceReference), object folderPath = default(object))
         {
             LinkedService = linkedService;
             FolderPath = folderPath;
@@ -51,10 +52,11 @@ public DataFlowStagingInfo()
         public LinkedServiceReference LinkedService { get; set; }
 
         /// <summary>
-        /// Gets or sets folder path for staging blob.
+        /// Gets or sets folder path for staging blob. Type: string (or
+        /// Expression with resultType string)
         /// </summary>
         [JsonProperty(PropertyName = "folderPath")]
-        public string FolderPath { get; set; }
+        public object FolderPath { get; set; }
 
         /// <summary>
         /// Validate the object.
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SsisPackageLocation.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SSISPackageLocation.cs
similarity index 100%
rename from sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SsisPackageLocation.cs
rename to sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SSISPackageLocation.cs
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SapOpenHubLinkedService.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SapOpenHubLinkedService.cs
index 4b53d397b7a6..9d570f5a6737 100644
--- a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SapOpenHubLinkedService.cs
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SapOpenHubLinkedService.cs
@@ -35,6 +35,13 @@ public SapOpenHubLinkedService()
         /// <summary>
         /// Initializes a new instance of the SapOpenHubLinkedService class.
         /// </summary>
+        /// <param name="additionalProperties">Unmatched properties from the
+        /// message are deserialized this collection</param>
+        /// <param name="connectVia">The integration runtime reference.</param>
+        /// <param name="description">Linked service description.</param>
+        /// <param name="parameters">Parameters for linked service.</param>
+        /// <param name="annotations">List of tags that can be used for
+        /// describing the linked service.</param>
         /// <param name="server">Host name of the SAP BW instance where the
         /// open hub destination is located. Type: string (or Expression with
         /// resultType string).</param>
@@ -46,34 +53,41 @@ public SapOpenHubLinkedService()
         /// where the open hub destination is located. (Usually a three-digit
         /// decimal number represented as a string) Type: string (or Expression
         /// with resultType string).</param>
-        /// <param name="additionalProperties">Unmatched properties from the
-        /// message are deserialized this collection</param>
-        /// <param name="connectVia">The integration runtime reference.</param>
-        /// <param name="description">Linked service description.</param>
-        /// <param name="parameters">Parameters for linked service.</param>
-        /// <param name="annotations">List of tags that can be used for
-        /// describing the linked service.</param>
         /// <param name="language">Language of the BW system where the open hub
         /// destination is located. The default value is EN. Type: string (or
         /// Expression with resultType string).</param>
+        /// <param name="systemId">SystemID of the SAP system where the table
+        /// is located. Type: string (or Expression with resultType
+        /// string).</param>
         /// <param name="userName">Username to access the SAP BW server where
         /// the open hub destination is located. Type: string (or Expression
         /// with resultType string).</param>
         /// <param name="password">Password to access the SAP BW server where
         /// the open hub destination is located.</param>
+        /// <param name="messageServer">The hostname of the SAP Message Server.
+        /// Type: string (or Expression with resultType string).</param>
+        /// <param name="messageServerService">The service name or port number
+        /// of the Message Server. Type: string (or Expression with resultType
+        /// string).</param>
+        /// <param name="logonGroup">The Logon Group for the SAP System. Type:
+        /// string (or Expression with resultType string).</param>
         /// <param name="encryptedCredential">The encrypted credential used for
         /// authentication. Credentials are encrypted using the integration
         /// runtime credential manager. Type: string (or Expression with
         /// resultType string).</param>
-        public SapOpenHubLinkedService(object server, object systemNumber, object clientId, IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), IntegrationRuntimeReference connectVia = default(IntegrationRuntimeReference), string description = default(string), IDictionary<string, ParameterSpecification> parameters = default(IDictionary<string, ParameterSpecification>), IList<object> annotations = default(IList<object>), object language = default(object), object userName = default(object), SecretBase password = default(SecretBase), object encryptedCredential = default(object))
+        public SapOpenHubLinkedService(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), IntegrationRuntimeReference connectVia = default(IntegrationRuntimeReference), string description = default(string), IDictionary<string, ParameterSpecification> parameters = default(IDictionary<string, ParameterSpecification>), IList<object> annotations = default(IList<object>), object server = default(object), object systemNumber = default(object), object clientId = default(object), object language = default(object), object systemId = default(object), object userName = default(object), SecretBase password = default(SecretBase), object messageServer = default(object), object messageServerService = default(object), object logonGroup = default(object), object encryptedCredential = default(object))
             : base(additionalProperties, connectVia, description, parameters, annotations)
         {
             Server = server;
             SystemNumber = systemNumber;
             ClientId = clientId;
             Language = language;
+            SystemId = systemId;
             UserName = userName;
             Password = password;
+            MessageServer = messageServer;
+            MessageServerService = messageServerService;
+            LogonGroup = logonGroup;
             EncryptedCredential = encryptedCredential;
             CustomInit();
         }
@@ -117,6 +131,13 @@ public SapOpenHubLinkedService()
         [JsonProperty(PropertyName = "typeProperties.language")]
         public object Language { get; set; }
 
+        /// <summary>
+        /// Gets or sets systemID of the SAP system where the table is located.
+        /// Type: string (or Expression with resultType string).
+        /// </summary>
+        [JsonProperty(PropertyName = "typeProperties.systemId")]
+        public object SystemId { get; set; }
+
         /// <summary>
         /// Gets or sets username to access the SAP BW server where the open
         /// hub destination is located. Type: string (or Expression with
@@ -132,6 +153,27 @@ public SapOpenHubLinkedService()
         [JsonProperty(PropertyName = "typeProperties.password")]
         public SecretBase Password { get; set; }
 
+        /// <summary>
+        /// Gets or sets the hostname of the SAP Message Server. Type: string
+        /// (or Expression with resultType string).
+        /// </summary>
+        [JsonProperty(PropertyName = "typeProperties.messageServer")]
+        public object MessageServer { get; set; }
+
+        /// <summary>
+        /// Gets or sets the service name or port number of the Message Server.
+        /// Type: string (or Expression with resultType string).
+        /// </summary>
+        [JsonProperty(PropertyName = "typeProperties.messageServerService")]
+        public object MessageServerService { get; set; }
+
+        /// <summary>
+        /// Gets or sets the Logon Group for the SAP System. Type: string (or
+        /// Expression with resultType string).
+        /// </summary>
+        [JsonProperty(PropertyName = "typeProperties.logonGroup")]
+        public object LogonGroup { get; set; }
+
         /// <summary>
         /// Gets or sets the encrypted credential used for authentication.
         /// Credentials are encrypted using the integration runtime credential
@@ -149,18 +191,6 @@ public SapOpenHubLinkedService()
         public override void Validate()
         {
             base.Validate();
-            if (Server == null)
-            {
-                throw new ValidationException(ValidationRules.CannotBeNull, "Server");
-            }
-            if (SystemNumber == null)
-            {
-                throw new ValidationException(ValidationRules.CannotBeNull, "SystemNumber");
-            }
-            if (ClientId == null)
-            {
-                throw new ValidationException(ValidationRules.CannotBeNull, "ClientId");
-            }
         }
     }
 }
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlDWSource.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlDWSource.cs
index 2a3fd9dba735..118d41686a6c 100644
--- a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlDWSource.cs
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlDWSource.cs
@@ -57,12 +57,19 @@ public SqlDWSource()
         /// stored procedure parameters. Example: "{Parameter1: {value: "1",
         /// type: "int"}}". Type: object (or Expression with resultType
         /// object), itemType: StoredProcedureParameter.</param>
-        public SqlDWSource(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object sourceRetryCount = default(object), object sourceRetryWait = default(object), object maxConcurrentConnections = default(object), object queryTimeout = default(object), IList<AdditionalColumns> additionalColumns = default(IList<AdditionalColumns>), object sqlReaderQuery = default(object), object sqlReaderStoredProcedureName = default(object), object storedProcedureParameters = default(object))
+        /// <param name="partitionOption">The partition mechanism that will be
+        /// used for Sql read in parallel. Possible values include: 'None',
+        /// 'PhysicalPartitionsOfTable', 'DynamicRange'</param>
+        /// <param name="partitionSettings">The settings that will be leveraged
+        /// for Sql source partitioning.</param>
+        public SqlDWSource(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object sourceRetryCount = default(object), object sourceRetryWait = default(object), object maxConcurrentConnections = default(object), object queryTimeout = default(object), IList<AdditionalColumns> additionalColumns = default(IList<AdditionalColumns>), object sqlReaderQuery = default(object), object sqlReaderStoredProcedureName = default(object), object storedProcedureParameters = default(object), string partitionOption = default(string), SqlPartitionSettings partitionSettings = default(SqlPartitionSettings))
             : base(additionalProperties, sourceRetryCount, sourceRetryWait, maxConcurrentConnections, queryTimeout, additionalColumns)
         {
             SqlReaderQuery = sqlReaderQuery;
             SqlReaderStoredProcedureName = sqlReaderStoredProcedureName;
             StoredProcedureParameters = storedProcedureParameters;
+            PartitionOption = partitionOption;
+            PartitionSettings = partitionSettings;
             CustomInit();
         }
 
@@ -95,5 +102,20 @@ public SqlDWSource()
         [JsonProperty(PropertyName = "storedProcedureParameters")]
         public object StoredProcedureParameters { get; set; }
 
+        /// <summary>
+        /// Gets or sets the partition mechanism that will be used for Sql read
+        /// in parallel. Possible values include: 'None',
+        /// 'PhysicalPartitionsOfTable', 'DynamicRange'
+        /// </summary>
+        [JsonProperty(PropertyName = "partitionOption")]
+        public string PartitionOption { get; set; }
+
+        /// <summary>
+        /// Gets or sets the settings that will be leveraged for Sql source
+        /// partitioning.
+        /// </summary>
+        [JsonProperty(PropertyName = "partitionSettings")]
+        public SqlPartitionSettings PartitionSettings { get; set; }
+
     }
 }
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlMISource.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlMISource.cs
index 96d8c313fa39..9ce8caf7515c 100644
--- a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlMISource.cs
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlMISource.cs
@@ -58,13 +58,20 @@ public SqlMISource()
         /// type: "int"}}".</param>
         /// <param name="produceAdditionalTypes">Which additional types to
         /// produce.</param>
-        public SqlMISource(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object sourceRetryCount = default(object), object sourceRetryWait = default(object), object maxConcurrentConnections = default(object), object queryTimeout = default(object), IList<AdditionalColumns> additionalColumns = default(IList<AdditionalColumns>), object sqlReaderQuery = default(object), object sqlReaderStoredProcedureName = default(object), IDictionary<string, StoredProcedureParameter> storedProcedureParameters = default(IDictionary<string, StoredProcedureParameter>), object produceAdditionalTypes = default(object))
+        /// <param name="partitionOption">The partition mechanism that will be
+        /// used for Sql read in parallel. Possible values include: 'None',
+        /// 'PhysicalPartitionsOfTable', 'DynamicRange'</param>
+        /// <param name="partitionSettings">The settings that will be leveraged
+        /// for Sql source partitioning.</param>
+        public SqlMISource(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object sourceRetryCount = default(object), object sourceRetryWait = default(object), object maxConcurrentConnections = default(object), object queryTimeout = default(object), IList<AdditionalColumns> additionalColumns = default(IList<AdditionalColumns>), object sqlReaderQuery = default(object), object sqlReaderStoredProcedureName = default(object), IDictionary<string, StoredProcedureParameter> storedProcedureParameters = default(IDictionary<string, StoredProcedureParameter>), object produceAdditionalTypes = default(object), string partitionOption = default(string), SqlPartitionSettings partitionSettings = default(SqlPartitionSettings))
             : base(additionalProperties, sourceRetryCount, sourceRetryWait, maxConcurrentConnections, queryTimeout, additionalColumns)
         {
             SqlReaderQuery = sqlReaderQuery;
             SqlReaderStoredProcedureName = sqlReaderStoredProcedureName;
             StoredProcedureParameters = storedProcedureParameters;
             ProduceAdditionalTypes = produceAdditionalTypes;
+            PartitionOption = partitionOption;
+            PartitionSettings = partitionSettings;
             CustomInit();
         }
 
@@ -102,5 +109,20 @@ public SqlMISource()
         [JsonProperty(PropertyName = "produceAdditionalTypes")]
         public object ProduceAdditionalTypes { get; set; }
 
+        /// <summary>
+        /// Gets or sets the partition mechanism that will be used for Sql read
+        /// in parallel. Possible values include: 'None',
+        /// 'PhysicalPartitionsOfTable', 'DynamicRange'
+        /// </summary>
+        [JsonProperty(PropertyName = "partitionOption")]
+        public string PartitionOption { get; set; }
+
+        /// <summary>
+        /// Gets or sets the settings that will be leveraged for Sql source
+        /// partitioning.
+        /// </summary>
+        [JsonProperty(PropertyName = "partitionSettings")]
+        public SqlPartitionSettings PartitionSettings { get; set; }
+
     }
 }
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlPartitionOption.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlPartitionOption.cs
new file mode 100644
index 000000000000..f65428093808
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlPartitionOption.cs
@@ -0,0 +1,23 @@
+// <auto-generated>
+// 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.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+// </auto-generated>
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+
+    /// <summary>
+    /// Defines values for SqlPartitionOption.
+    /// </summary>
+    public static class SqlPartitionOption
+    {
+        public const string None = "None";
+        public const string PhysicalPartitionsOfTable = "PhysicalPartitionsOfTable";
+        public const string DynamicRange = "DynamicRange";
+    }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlPartitionSettings.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlPartitionSettings.cs
new file mode 100644
index 000000000000..f7f7d7b3be9b
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlPartitionSettings.cs
@@ -0,0 +1,93 @@
+// <auto-generated>
+// 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.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+// </auto-generated>
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+    using Newtonsoft.Json;
+    using System.Linq;
+
+    /// <summary>
+    /// The settings that will be leveraged for Sql source partitioning.
+    /// </summary>
+    public partial class SqlPartitionSettings
+    {
+        /// <summary>
+        /// Initializes a new instance of the SqlPartitionSettings class.
+        /// </summary>
+        public SqlPartitionSettings()
+        {
+            CustomInit();
+        }
+
+        /// <summary>
+        /// Initializes a new instance of the SqlPartitionSettings class.
+        /// </summary>
+        /// <param name="partitionColumnName">The name of the column in integer
+        /// or datetime type that will be used for proceeding partitioning. If
+        /// not specified, the primary key of the table is auto-detected and
+        /// used as the partition column. Type: string (or Expression with
+        /// resultType string).</param>
+        /// <param name="partitionUpperBound">The maximum value of the
+        /// partition column for partition range splitting. This value is used
+        /// to decide the partition stride, not for filtering the rows in
+        /// table. All rows in the table or query result will be partitioned
+        /// and copied. Type: string (or Expression with resultType
+        /// string).</param>
+        /// <param name="partitionLowerBound">The minimum value of the
+        /// partition column for partition range splitting. This value is used
+        /// to decide the partition stride, not for filtering the rows in
+        /// table. All rows in the table or query result will be partitioned
+        /// and copied. Type: string (or Expression with resultType
+        /// string).</param>
+        public SqlPartitionSettings(object partitionColumnName = default(object), object partitionUpperBound = default(object), object partitionLowerBound = default(object))
+        {
+            PartitionColumnName = partitionColumnName;
+            PartitionUpperBound = partitionUpperBound;
+            PartitionLowerBound = partitionLowerBound;
+            CustomInit();
+        }
+
+        /// <summary>
+        /// An initialization method that performs custom operations like setting defaults
+        /// </summary>
+        partial void CustomInit();
+
+        /// <summary>
+        /// Gets or sets the name of the column in integer or datetime type
+        /// that will be used for proceeding partitioning. If not specified,
+        /// the primary key of the table is auto-detected and used as the
+        /// partition column. Type: string (or Expression with resultType
+        /// string).
+        /// </summary>
+        [JsonProperty(PropertyName = "partitionColumnName")]
+        public object PartitionColumnName { get; set; }
+
+        /// <summary>
+        /// Gets or sets the maximum value of the partition column for
+        /// partition range splitting. This value is used to decide the
+        /// partition stride, not for filtering the rows in table. All rows in
+        /// the table or query result will be partitioned and copied. Type:
+        /// string (or Expression with resultType string).
+        /// </summary>
+        [JsonProperty(PropertyName = "partitionUpperBound")]
+        public object PartitionUpperBound { get; set; }
+
+        /// <summary>
+        /// Gets or sets the minimum value of the partition column for
+        /// partition range splitting. This value is used to decide the
+        /// partition stride, not for filtering the rows in table. All rows in
+        /// the table or query result will be partitioned and copied. Type:
+        /// string (or Expression with resultType string).
+        /// </summary>
+        [JsonProperty(PropertyName = "partitionLowerBound")]
+        public object PartitionLowerBound { get; set; }
+
+    }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlServerSource.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlServerSource.cs
index c1cbb89d9202..fc60faec5577 100644
--- a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlServerSource.cs
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlServerSource.cs
@@ -58,13 +58,20 @@ public SqlServerSource()
         /// type: "int"}}".</param>
         /// <param name="produceAdditionalTypes">Which additional types to
         /// produce.</param>
-        public SqlServerSource(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object sourceRetryCount = default(object), object sourceRetryWait = default(object), object maxConcurrentConnections = default(object), object queryTimeout = default(object), IList<AdditionalColumns> additionalColumns = default(IList<AdditionalColumns>), object sqlReaderQuery = default(object), object sqlReaderStoredProcedureName = default(object), IDictionary<string, StoredProcedureParameter> storedProcedureParameters = default(IDictionary<string, StoredProcedureParameter>), object produceAdditionalTypes = default(object))
+        /// <param name="partitionOption">The partition mechanism that will be
+        /// used for Sql read in parallel. Possible values include: 'None',
+        /// 'PhysicalPartitionsOfTable', 'DynamicRange'</param>
+        /// <param name="partitionSettings">The settings that will be leveraged
+        /// for Sql source partitioning.</param>
+        public SqlServerSource(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object sourceRetryCount = default(object), object sourceRetryWait = default(object), object maxConcurrentConnections = default(object), object queryTimeout = default(object), IList<AdditionalColumns> additionalColumns = default(IList<AdditionalColumns>), object sqlReaderQuery = default(object), object sqlReaderStoredProcedureName = default(object), IDictionary<string, StoredProcedureParameter> storedProcedureParameters = default(IDictionary<string, StoredProcedureParameter>), object produceAdditionalTypes = default(object), string partitionOption = default(string), SqlPartitionSettings partitionSettings = default(SqlPartitionSettings))
             : base(additionalProperties, sourceRetryCount, sourceRetryWait, maxConcurrentConnections, queryTimeout, additionalColumns)
         {
             SqlReaderQuery = sqlReaderQuery;
             SqlReaderStoredProcedureName = sqlReaderStoredProcedureName;
             StoredProcedureParameters = storedProcedureParameters;
             ProduceAdditionalTypes = produceAdditionalTypes;
+            PartitionOption = partitionOption;
+            PartitionSettings = partitionSettings;
             CustomInit();
         }
 
@@ -101,5 +108,20 @@ public SqlServerSource()
         [JsonProperty(PropertyName = "produceAdditionalTypes")]
         public object ProduceAdditionalTypes { get; set; }
 
+        /// <summary>
+        /// Gets or sets the partition mechanism that will be used for Sql read
+        /// in parallel. Possible values include: 'None',
+        /// 'PhysicalPartitionsOfTable', 'DynamicRange'
+        /// </summary>
+        [JsonProperty(PropertyName = "partitionOption")]
+        public string PartitionOption { get; set; }
+
+        /// <summary>
+        /// Gets or sets the settings that will be leveraged for Sql source
+        /// partitioning.
+        /// </summary>
+        [JsonProperty(PropertyName = "partitionSettings")]
+        public SqlPartitionSettings PartitionSettings { get; set; }
+
     }
 }
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlSource.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlSource.cs
index 7fab6677c3f0..3edbbb834988 100644
--- a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlSource.cs
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlSource.cs
@@ -61,13 +61,20 @@ public SqlSource()
         /// ReadCommitted/ReadUncommitted/RepeatableRead/Serializable/Snapshot.
         /// The default value is ReadCommitted. Type: string (or Expression
         /// with resultType string).</param>
-        public SqlSource(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object sourceRetryCount = default(object), object sourceRetryWait = default(object), object maxConcurrentConnections = default(object), object queryTimeout = default(object), IList<AdditionalColumns> additionalColumns = default(IList<AdditionalColumns>), object sqlReaderQuery = default(object), object sqlReaderStoredProcedureName = default(object), IDictionary<string, StoredProcedureParameter> storedProcedureParameters = default(IDictionary<string, StoredProcedureParameter>), object isolationLevel = default(object))
+        /// <param name="partitionOption">The partition mechanism that will be
+        /// used for Sql read in parallel. Possible values include: 'None',
+        /// 'PhysicalPartitionsOfTable', 'DynamicRange'</param>
+        /// <param name="partitionSettings">The settings that will be leveraged
+        /// for Sql source partitioning.</param>
+        public SqlSource(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object sourceRetryCount = default(object), object sourceRetryWait = default(object), object maxConcurrentConnections = default(object), object queryTimeout = default(object), IList<AdditionalColumns> additionalColumns = default(IList<AdditionalColumns>), object sqlReaderQuery = default(object), object sqlReaderStoredProcedureName = default(object), IDictionary<string, StoredProcedureParameter> storedProcedureParameters = default(IDictionary<string, StoredProcedureParameter>), object isolationLevel = default(object), string partitionOption = default(string), SqlPartitionSettings partitionSettings = default(SqlPartitionSettings))
             : base(additionalProperties, sourceRetryCount, sourceRetryWait, maxConcurrentConnections, queryTimeout, additionalColumns)
         {
             SqlReaderQuery = sqlReaderQuery;
             SqlReaderStoredProcedureName = sqlReaderStoredProcedureName;
             StoredProcedureParameters = storedProcedureParameters;
             IsolationLevel = isolationLevel;
+            PartitionOption = partitionOption;
+            PartitionSettings = partitionSettings;
             CustomInit();
         }
 
@@ -108,5 +115,20 @@ public SqlSource()
         [JsonProperty(PropertyName = "isolationLevel")]
         public object IsolationLevel { get; set; }
 
+        /// <summary>
+        /// Gets or sets the partition mechanism that will be used for Sql read
+        /// in parallel. Possible values include: 'None',
+        /// 'PhysicalPartitionsOfTable', 'DynamicRange'
+        /// </summary>
+        [JsonProperty(PropertyName = "partitionOption")]
+        public string PartitionOption { get; set; }
+
+        /// <summary>
+        /// Gets or sets the settings that will be leveraged for Sql source
+        /// partitioning.
+        /// </summary>
+        [JsonProperty(PropertyName = "partitionSettings")]
+        public SqlPartitionSettings PartitionSettings { get; set; }
+
     }
 }
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/SdkInfo_DataFactoryManagementClient.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/SdkInfo_DataFactoryManagementClient.cs
index a1c453f7fb67..b31348b3961b 100644
--- a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/SdkInfo_DataFactoryManagementClient.cs
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/SdkInfo_DataFactoryManagementClient.cs
@@ -37,16 +37,5 @@ public static IEnumerable<Tuple<string, string, string>> ApiInfo_DataFactoryMana
               }.AsEnumerable();
           }
       }
-      // BEGIN: Code Generation Metadata Section
-      public static readonly String AutoRestVersion = "v2";
-      public static readonly String AutoRestBootStrapperVersion = "autorest@2.0.4413";
-      public static readonly String AutoRestCmdExecuted = "cmd.exe /c autorest.cmd https://github.com/Azure/azure-rest-api-specs/blob/master/specification/datafactory/resource-manager/readme.md --csharp --version=v2 --reflect-api-versions --tag=package-2018-06 --csharp-sdks-folder=C:\\Users\\rizh\\Documents\\azure-sdk-for-net\\sdk";
-      public static readonly String GithubForkName = "Azure";
-      public static readonly String GithubBranchName = "master";
-      public static readonly String GithubCommidId = "09ac2b33d780dbf2f74de2083012f62aaa33c451";
-      public static readonly String CodeGenerationErrors = "";
-      public static readonly String GithubRepoName = "azure-rest-api-specs";
-      // END: Code Generation Metadata Section
   }
 }
-