Share via


HDInsightStreamingActivity Constructor

Definition

Initializes a new instance of HDInsightStreamingActivity.

public HDInsightStreamingActivity (string name, Azure.Core.Expressions.DataFactory.DataFactoryElement<string> mapper, Azure.Core.Expressions.DataFactory.DataFactoryElement<string> reducer, Azure.Core.Expressions.DataFactory.DataFactoryElement<string> input, Azure.Core.Expressions.DataFactory.DataFactoryElement<string> output, System.Collections.Generic.IEnumerable<BinaryData> filePaths);
new Azure.ResourceManager.DataFactory.Models.HDInsightStreamingActivity : string * Azure.Core.Expressions.DataFactory.DataFactoryElement<string> * Azure.Core.Expressions.DataFactory.DataFactoryElement<string> * Azure.Core.Expressions.DataFactory.DataFactoryElement<string> * Azure.Core.Expressions.DataFactory.DataFactoryElement<string> * seq<BinaryData> -> Azure.ResourceManager.DataFactory.Models.HDInsightStreamingActivity
Public Sub New (name As String, mapper As DataFactoryElement(Of String), reducer As DataFactoryElement(Of String), input As DataFactoryElement(Of String), output As DataFactoryElement(Of String), filePaths As IEnumerable(Of BinaryData))

Parameters

name
String

Activity name.

mapper
DataFactoryElement<String>

Mapper executable name. Type: string (or Expression with resultType string).

reducer
DataFactoryElement<String>

Reducer executable name. Type: string (or Expression with resultType string).

input
DataFactoryElement<String>

Input blob path. Type: string (or Expression with resultType string).

output
DataFactoryElement<String>

Output blob path. Type: string (or Expression with resultType string).

filePaths
IEnumerable<BinaryData>

Paths to streaming job files. Can be directories.

Exceptions

name, mapper, reducer, input, output or filePaths is null.

Applies to