Class DataFlowStreamDestination<TInput>

{{< /rawhtml >}} ```C# public abstract class DataFlowStreamDestination : DataFlowDestination, IDataFlowStreamDestination, IDataFlowDestination, IDataFlowStreamDestination, IDataFlowDestination, IDataFlowComponent, ILoggableTask ``` {{< rawhtml >}}

Type Parameters

Name	Description
TInput	Type of ingoing data

Properties

AzureBlobStorage

Use this to pass your AzureBlobStorage connection information. There are different methods to connect with Azure Blob Storage: Option 1: provide an existing BlockBlobClient Option 2: create BlockBlobClient based on the Uri and optional credential tokens - the Uri needs to be the blob url Option 3: create BlobkBlobClient with provided ConnectionString and ContainerName, the Uri is then the name of the blob

Declaration

{{< /rawhtml >}} ```C# public AzureBlobStorageConfiguration AzureBlobStorage { get; set; } ``` {{< rawhtml >}}

Property Value

Type	Description
AzureBlobStorageConfiguration

CreateStreamWriter

By default, stream are created internally based on Uri & ResourceType. If you already have an existing stream, use this function to returns a new StreamWriter based on this stream.

Declaration

{{< /rawhtml >}} ```C# public Func CreateStreamWriter { get; set; } ``` {{< rawhtml >}}

Property Value

Type	Description
Func<string, StreamWriter>

Encoding

Encoding used to write data into the source file or web request.

Declaration

{{< /rawhtml >}} ```C# public Encoding Encoding { get; set; } ``` {{< rawhtml >}}

Property Value

Type	Description
Encoding

GetNextUri

This function returns the next url that is used for writing data. It will used until HasNextUri returns false. The incoming StreamMetaData holds information about the current progress and currently processed data row. This property can be used if you want to write into multiple files or send data into different web services.

Declaration

{{< /rawhtml >}} ```C# public Func GetNextUri { get; set; } ``` {{< rawhtml >}}

Property Value

Type	Description
Func<StreamMetaData, TInput, string>

HasNextUri

This func determines if the next data record should be written into another location. StreamMetaData has information about the current progress and currently processed data row.

Declaration

{{< /rawhtml >}} ```C# public Func HasNextUri { get; set; } ``` {{< rawhtml >}}

Property Value

Type	Description
Func<StreamMetaData, TInput, bool>

HttpClient

The System.Net.HttpClient used to connect with the destination (only needed when the ResourceType is Http.

Declaration

{{< /rawhtml >}} ```C# public HttpClient HttpClient { get; set; } ``` {{< rawhtml >}}

Property Value

Type	Description
HttpClient

HttpContentType

The content type used when sending the http request content.

Declaration

{{< /rawhtml >}} ```C# public virtual string HttpContentType { get; set; } ``` {{< rawhtml >}}

Property Value

Type	Description
string

HttpRequestMessage

The System.Net.Http.HttpRequestMessage used for the request in the HttpClient. Use this property to add additional header data type or to change the http method (e.g. for POST requests).

Declaration

{{< /rawhtml >}} ```C# public HttpRequestMessage HttpRequestMessage { get; set; } ``` {{< rawhtml >}}

Property Value

Type	Description
HttpRequestMessage

HttpResponseMessage

The System.Net.HttpResponseMessage returned from the current request. The response message is avaiable after all data rows were sent to the destination.

Declaration

{{< /rawhtml >}} ```C# public HttpResponseMessage HttpResponseMessage { get; } ``` {{< rawhtml >}}

Property Value

Type	Description
HttpResponseMessage

NewMetaDataObject

Declaration

{{< /rawhtml >}} ```C# protected StreamMetaData NewMetaDataObject { get; } ``` {{< rawhtml >}}

Property Value

Type	Description
StreamMetaData

ResourceType

Specifies the resource type. Use ResourceType.File if you want to write into a file (default) Use ResourceType.Http to write into a web endpoint.

Declaration

{{< /rawhtml >}} ```C# public ResourceType ResourceType { get; set; } ``` {{< rawhtml >}}

Property Value

Type	Description
ResourceType

StreamWriter

The stream writer used for the current request.

Declaration

{{< /rawhtml >}} ```C# public StreamWriter StreamWriter { get; protected set; } ``` {{< rawhtml >}}

Property Value

Type	Description
StreamWriter

Uri

The Url of the webservice (e.g. https://test.com/foo) or the file name (relative or absolute)

Declaration

{{< /rawhtml >}} ```C# public string Uri { get; set; } ``` {{< rawhtml >}}

Property Value

Type	Description
string

WriteUri

The Uri used for the current write operation- this will only be different to the Uri if you use the GetNextUri and HasNextUri functions.

Declaration

{{< /rawhtml >}} ```C# public string WriteUri { get; protected set; } ``` {{< rawhtml >}}

Property Value

Type	Description
string

Methods

CheckParameter()

Declaration

{{< /rawhtml >}} ```C# protected override void CheckParameter() ``` {{< rawhtml >}}

Overrides

DataFlowComponent.CheckParameter()

CleanUpOnFaulted(Exception)

Declaration

{{< /rawhtml >}} ```C# protected override void CleanUpOnFaulted(Exception e) ``` {{< rawhtml >}}

Parameters

Type	Name	Description
Exception	e

Overrides

DataFlowComponent.CleanUpOnFaulted(Exception)

CleanUpOnSuccess()

Declaration

{{< /rawhtml >}} ```C# protected override void CleanUpOnSuccess() ``` {{< rawhtml >}}

Overrides

DataFlowComponent.CleanUpOnSuccess()

CloseStream()

Declaration

{{< /rawhtml >}} ```C# protected abstract void CloseStream() ``` {{< rawhtml >}}

InitComponent()

Declaration

{{< /rawhtml >}} ```C# protected override void InitComponent() ``` {{< rawhtml >}}

Overrides

DataFlowDestination<TInput>.InitComponent()

InitStream()

Declaration

{{< /rawhtml >}} ```C# protected abstract void InitStream() ``` {{< rawhtml >}}

PrepareParameterForCheck()

Declaration

{{< /rawhtml >}} ```C# protected override void PrepareParameterForCheck() ``` {{< rawhtml >}}

Overrides

DataFlowComponent.PrepareParameterForCheck()

PrepareStreamForBatchProcessing(TInput[])

Declaration

{{< /rawhtml >}} ```C# protected void PrepareStreamForBatchProcessing(TInput[] data) ``` {{< rawhtml >}}

Parameters

Type	Name	Description
TInput[]	data

WriteData(TInput)

Declaration

{{< /rawhtml >}} ```C# protected void WriteData(TInput data) ``` {{< rawhtml >}}

Parameters

Type	Name	Description
TInput	data

WriteIntoStream(TInput)

Declaration

{{< /rawhtml >}} ```C# protected abstract void WriteIntoStream(TInput data) ``` {{< rawhtml >}}

Parameters

Type	Name	Description
TInput	data

Implements

IDataFlowStreamDestination<TInput>

IDataFlowDestination<TInput>

IDataFlowStreamDestination

IDataFlowDestination

IDataFlowComponent

ILoggableTask