[Data Factory]Add support for data flow (Azure#7765)

* Add support for data flow

* address feedback

eng/mgmt/mgmtmetadata/datafactory_resource-manager.txt

@@ -3,12 +3,12 @@ AutoRest installed successfully.
 Commencing code generation
 Generating CSharp code
 Executing AutoRest command
-cmd.exe /c autorest.cmd https://github.com/Azure/azure-rest-api-specs/blob/master/specification/datafactory/resource-manager/readme.md --csharp --version=latest --reflect-api-versions --tag=package-2018-06 --csharp-sdks-folder=C:\azure-sdk-for-net\sdk
-2019-09-24 03:31:37 UTC
+cmd.exe /c autorest.cmd https://github.com/Azure/azure-rest-api-specs/blob/master/specification/datafactory/resource-manager/readme.md --csharp --version=latest --reflect-api-versions --tag=package-2018-06 --csharp-sdks-folder=D:\GitHub\azure-sdk-for-net\sdk
+2019-09-25 22:44:08 UTC
 Azure-rest-api-specs repository information
 GitHub fork: Azure
 Branch:      master
-Commit:      6bec7452e59b579f0a1e203b937bf1157eb8af1e
+Commit:      6d4e0d294d568a37b1f3421b789290934517d115
 AutoRest information
 Requested version: latest
 Bootstrapper version:    autorest@2.0.4283

sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/DataFactoryManagementClient.cs

@@ -145,6 +145,16 @@ public partial class DataFactoryManagementClient : ServiceClient<DataFactoryMana
         /// </summary>
         public virtual IRerunTriggersOperations RerunTriggers { get; private set; }
 
+        /// <summary>
+        /// Gets the IDataFlowsOperations.
+        /// </summary>
+        public virtual IDataFlowsOperations DataFlows { get; private set; }
+
+        /// <summary>
+        /// Gets the IDataFlowDebugSessionOperations.
+        /// </summary>
+        public virtual IDataFlowDebugSessionOperations DataFlowDebugSession { get; private set; }
+
         /// <summary>
         /// Initializes a new instance of the DataFactoryManagementClient class.
         /// </summary>
@@ -400,6 +410,8 @@ private void Initialize()
             Triggers = new TriggersOperations(this);
             TriggerRuns = new TriggerRunsOperations(this);
             RerunTriggers = new RerunTriggersOperations(this);
+            DataFlows = new DataFlowsOperations(this);
+            DataFlowDebugSession = new DataFlowDebugSessionOperations(this);
             BaseUri = new System.Uri("https://management.azure.com");
             ApiVersion = "2018-06-01";
             AcceptLanguage = "en-US";
@@ -447,6 +459,8 @@ private void Initialize()
             DeserializationSettings.Converters.Add(new PolymorphicDeserializeJsonConverter<Activity>("type"));
             SerializationSettings.Converters.Add(new PolymorphicSerializeJsonConverter<Trigger>("type"));
             DeserializationSettings.Converters.Add(new PolymorphicDeserializeJsonConverter<Trigger>("type"));
+            SerializationSettings.Converters.Add(new PolymorphicSerializeJsonConverter<DataFlow>("type"));
+            DeserializationSettings.Converters.Add(new PolymorphicDeserializeJsonConverter<DataFlow>("type"));
             SerializationSettings.Converters.Add(new PolymorphicSerializeJsonConverter<DependencyReference>("type"));
             DeserializationSettings.Converters.Add(new PolymorphicDeserializeJsonConverter<DependencyReference>("type"));
             SerializationSettings.Converters.Add(new PolymorphicSerializeJsonConverter<WebLinkedServiceTypeProperties>("authenticationType"));

sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/DataFlowDebugSessionOperationsExtensions.cs

@@ -0,0 +1,280 @@
+// <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
+{
+    using Microsoft.Rest;
+    using Microsoft.Rest.Azure;
+    using Models;
+    using System.Threading;
+    using System.Threading.Tasks;
+
+    /// <summary>
+    /// Extension methods for DataFlowDebugSessionOperations.
+    /// </summary>
+    public static partial class DataFlowDebugSessionOperationsExtensions
+    {
+            /// <summary>
+            /// Creates a data flow debug session.
+            /// </summary>
+            /// <param name='operations'>
+            /// The operations group for this extension method.
+            /// </param>
+            /// <param name='resourceGroupName'>
+            /// The resource group name.
+            /// </param>
+            /// <param name='factoryName'>
+            /// The factory name.
+            /// </param>
+            /// <param name='request'>
+            /// Data flow debug session definition
+            /// </param>
+            public static CreateDataFlowDebugSessionResponse Create(this IDataFlowDebugSessionOperations operations, string resourceGroupName, string factoryName, CreateDataFlowDebugSessionRequest request)
+            {
+                return operations.CreateAsync(resourceGroupName, factoryName, request).GetAwaiter().GetResult();
+            }
+
+            /// <summary>
+            /// Creates a data flow debug session.
+            /// </summary>
+            /// <param name='operations'>
+            /// The operations group for this extension method.
+            /// </param>
+            /// <param name='resourceGroupName'>
+            /// The resource group name.
+            /// </param>
+            /// <param name='factoryName'>
+            /// The factory name.
+            /// </param>
+            /// <param name='request'>
+            /// Data flow debug session definition
+            /// </param>
+            /// <param name='cancellationToken'>
+            /// The cancellation token.
+            /// </param>
+            public static async Task<CreateDataFlowDebugSessionResponse> CreateAsync(this IDataFlowDebugSessionOperations operations, string resourceGroupName, string factoryName, CreateDataFlowDebugSessionRequest request, CancellationToken cancellationToken = default(CancellationToken))
+            {
+                using (var _result = await operations.CreateWithHttpMessagesAsync(resourceGroupName, factoryName, request, null, cancellationToken).ConfigureAwait(false))
+                {
+                    return _result.Body;
+                }
+            }
+
+            /// <summary>
+            /// Query all active data flow debug sessions.
+            /// </summary>
+            /// <param name='operations'>
+            /// The operations group for this extension method.
+            /// </param>
+            /// <param name='resourceGroupName'>
+            /// The resource group name.
+            /// </param>
+            /// <param name='factoryName'>
+            /// The factory name.
+            /// </param>
+            public static IPage<DataFlowDebugSessionInfo> QueryByFactory(this IDataFlowDebugSessionOperations operations, string resourceGroupName, string factoryName)
+            {
+                return operations.QueryByFactoryAsync(resourceGroupName, factoryName).GetAwaiter().GetResult();
+            }
+
+            /// <summary>
+            /// Query all active data flow debug sessions.
+            /// </summary>
+            /// <param name='operations'>
+            /// The operations group for this extension method.
+            /// </param>
+            /// <param name='resourceGroupName'>
+            /// The resource group name.
+            /// </param>
+            /// <param name='factoryName'>
+            /// The factory name.
+            /// </param>
+            /// <param name='cancellationToken'>
+            /// The cancellation token.
+            /// </param>
+            public static async Task<IPage<DataFlowDebugSessionInfo>> QueryByFactoryAsync(this IDataFlowDebugSessionOperations operations, string resourceGroupName, string factoryName, CancellationToken cancellationToken = default(CancellationToken))
+            {
+                using (var _result = await operations.QueryByFactoryWithHttpMessagesAsync(resourceGroupName, factoryName, null, cancellationToken).ConfigureAwait(false))
+                {
+                    return _result.Body;
+                }
+            }
+
+            /// <summary>
+            /// Add a data flow into debug session.
+            /// </summary>
+            /// <param name='operations'>
+            /// The operations group for this extension method.
+            /// </param>
+            /// <param name='resourceGroupName'>
+            /// The resource group name.
+            /// </param>
+            /// <param name='factoryName'>
+            /// The factory name.
+            /// </param>
+            /// <param name='request'>
+            /// Data flow debug session definition with debug content.
+            /// </param>
+            public static AddDataFlowToDebugSessionResponse AddDataFlow(this IDataFlowDebugSessionOperations operations, string resourceGroupName, string factoryName, DataFlowDebugPackage request)
+            {
+                return operations.AddDataFlowAsync(resourceGroupName, factoryName, request).GetAwaiter().GetResult();
+            }
+
+            /// <summary>
+            /// Add a data flow into debug session.
+            /// </summary>
+            /// <param name='operations'>
+            /// The operations group for this extension method.
+            /// </param>
+            /// <param name='resourceGroupName'>
+            /// The resource group name.
+            /// </param>
+            /// <param name='factoryName'>
+            /// The factory name.
+            /// </param>
+            /// <param name='request'>
+            /// Data flow debug session definition with debug content.
+            /// </param>
+            /// <param name='cancellationToken'>
+            /// The cancellation token.
+            /// </param>
+            public static async Task<AddDataFlowToDebugSessionResponse> AddDataFlowAsync(this IDataFlowDebugSessionOperations operations, string resourceGroupName, string factoryName, DataFlowDebugPackage request, CancellationToken cancellationToken = default(CancellationToken))
+            {
+                using (var _result = await operations.AddDataFlowWithHttpMessagesAsync(resourceGroupName, factoryName, request, null, cancellationToken).ConfigureAwait(false))
+                {
+                    return _result.Body;
+                }
+            }
+
+            /// <summary>
+            /// Deletes a data flow debug session.
+            /// </summary>
+            /// <param name='operations'>
+            /// The operations group for this extension method.
+            /// </param>
+            /// <param name='resourceGroupName'>
+            /// The resource group name.
+            /// </param>
+            /// <param name='factoryName'>
+            /// The factory name.
+            /// </param>
+            /// <param name='request'>
+            /// Data flow debug session definition for deletion
+            /// </param>
+            public static void Delete(this IDataFlowDebugSessionOperations operations, string resourceGroupName, string factoryName, DeleteDataFlowDebugSessionRequest request)
+            {
+                operations.DeleteAsync(resourceGroupName, factoryName, request).GetAwaiter().GetResult();
+            }
+
+            /// <summary>
+            /// Deletes a data flow debug session.
+            /// </summary>
+            /// <param name='operations'>
+            /// The operations group for this extension method.
+            /// </param>
+            /// <param name='resourceGroupName'>
+            /// The resource group name.
+            /// </param>
+            /// <param name='factoryName'>
+            /// The factory name.
+            /// </param>
+            /// <param name='request'>
+            /// Data flow debug session definition for deletion
+            /// </param>
+            /// <param name='cancellationToken'>
+            /// The cancellation token.
+            /// </param>
+            public static async Task DeleteAsync(this IDataFlowDebugSessionOperations operations, string resourceGroupName, string factoryName, DeleteDataFlowDebugSessionRequest request, CancellationToken cancellationToken = default(CancellationToken))
+            {
+                (await operations.DeleteWithHttpMessagesAsync(resourceGroupName, factoryName, request, null, cancellationToken).ConfigureAwait(false)).Dispose();
+            }
+
+            /// <summary>
+            /// Execute a data flow debug command.
+            /// </summary>
+            /// <param name='operations'>
+            /// The operations group for this extension method.
+            /// </param>
+            /// <param name='resourceGroupName'>
+            /// The resource group name.
+            /// </param>
+            /// <param name='factoryName'>
+            /// The factory name.
+            /// </param>
+            /// <param name='request'>
+            /// Data flow debug command definition.
+            /// </param>
+            public static DataFlowDebugCommandResponse ExecuteCommand(this IDataFlowDebugSessionOperations operations, string resourceGroupName, string factoryName, DataFlowDebugCommandRequest request)
+            {
+                return operations.ExecuteCommandAsync(resourceGroupName, factoryName, request).GetAwaiter().GetResult();
+            }
+
+            /// <summary>
+            /// Execute a data flow debug command.
+            /// </summary>
+            /// <param name='operations'>
+            /// The operations group for this extension method.
+            /// </param>
+            /// <param name='resourceGroupName'>
+            /// The resource group name.
+            /// </param>
+            /// <param name='factoryName'>
+            /// The factory name.
+            /// </param>
+            /// <param name='request'>
+            /// Data flow debug command definition.
+            /// </param>
+            /// <param name='cancellationToken'>
+            /// The cancellation token.
+            /// </param>
+            public static async Task<DataFlowDebugCommandResponse> ExecuteCommandAsync(this IDataFlowDebugSessionOperations operations, string resourceGroupName, string factoryName, DataFlowDebugCommandRequest request, CancellationToken cancellationToken = default(CancellationToken))
+            {
+                using (var _result = await operations.ExecuteCommandWithHttpMessagesAsync(resourceGroupName, factoryName, request, null, cancellationToken).ConfigureAwait(false))
+                {
+                    return _result.Body;
+                }
+            }
+
+            /// <summary>
+            /// Query all active data flow debug sessions.
+            /// </summary>
+            /// <param name='operations'>
+            /// The operations group for this extension method.
+            /// </param>
+            /// <param name='nextPageLink'>
+            /// The NextLink from the previous successful call to List operation.
+            /// </param>
+            public static IPage<DataFlowDebugSessionInfo> QueryByFactoryNext(this IDataFlowDebugSessionOperations operations, string nextPageLink)
+            {
+                return operations.QueryByFactoryNextAsync(nextPageLink).GetAwaiter().GetResult();
+            }
+
+            /// <summary>
+            /// Query all active data flow debug sessions.
+            /// </summary>
+            /// <param name='operations'>
+            /// The operations group for this extension method.
+            /// </param>
+            /// <param name='nextPageLink'>
+            /// The NextLink from the previous successful call to List operation.
+            /// </param>
+            /// <param name='cancellationToken'>
+            /// The cancellation token.
+            /// </param>
+            public static async Task<IPage<DataFlowDebugSessionInfo>> QueryByFactoryNextAsync(this IDataFlowDebugSessionOperations operations, string nextPageLink, CancellationToken cancellationToken = default(CancellationToken))
+            {
+                using (var _result = await operations.QueryByFactoryNextWithHttpMessagesAsync(nextPageLink, null, cancellationToken).ConfigureAwait(false))
+                {
+                    return _result.Body;
+                }
+            }
+
+    }
+}