Class DataFlowDestination<TInput>

Inheritance
System.Object
LoggableTask
DataFlowComponent
DataFlowDestination<TInput>
ConcurrentMemoryDestination<TInput>
CustomDestination<TInput>
MemoryDestination<TInput>
VoidDestination<TInput>
DataFlowStreamDestination<TInput>
Inherited Members
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.ToString()
Namespace: ETLBox.DataFlow
Assembly: ETLBox.dll
Syntax
public abstract class DataFlowDestination<TInput> : DataFlowComponent, ILoggableTask, IDataFlowLogging, IDataFlowDestination<TInput>, IDataFlowDestination, IDataFlowComponent
Type Parameters
Name Description
TInput

Properties

TargetAction

Declaration
protected virtual ActionBlock<TInput> TargetAction { get; set; }
Property Value
Type Description
System.Threading.Tasks.Dataflow.ActionBlock<TInput>

TargetBlock

TargetBlock from the underlying TPL.Dataflow which is used as output buffer for the component.

Declaration
public ITargetBlock<TInput> TargetBlock { get; }
Property Value
Type Description
System.Threading.Tasks.Dataflow.ITargetBlock<TInput>

Methods

LinkErrorTo(IDataFlowDestination<ETLBoxError>)

If an error occurs in the component, by default the component will throw an exception and stop execution. If you use the error linking, any erroneous records will catched and redirected.

Declaration
public IDataFlowSource<ETLBoxError> LinkErrorTo(IDataFlowDestination<ETLBoxError> target)
Parameters
Type Name Description
IDataFlowDestination<ETLBoxError> target

The target for erroneous rows.
Returns
Type Description
IDataFlowSource<ETLBoxError>

The linked component.

Wait()

Waits for the completion of the component.

Declaration
public void Wait()

Implements