Class DataFlowDestination<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
NameDescription
TInput

Fields

Buffer

Declaration
    protected BatchBlock<TInput> Buffer
Field Value
TypeDescription
System.Threading.Tasks.Dataflow.BatchBlock<TInput>

InternalBatchSize

Declaration
    protected int InternalBatchSize
Field Value
TypeDescription
System.Int32

Properties

BufferTargetAction

Declaration
    protected ActionBlock<TInput[]> BufferTargetAction { get; set; }
Property Value
TypeDescription
System.Threading.Tasks.Dataflow.ActionBlock<TInput[]>

TargetAction

Declaration
    protected ActionBlock<TInput> TargetAction { get; set; }
Property Value
TypeDescription
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
TypeDescription
System.Threading.Tasks.Dataflow.ITargetBlock<TInput>

UseBufferBlock

Declaration
    protected virtual bool UseBufferBlock { get; set; }
Property Value
TypeDescription
System.Boolean

Methods

InitComponent()

Declaration
    protected override void InitComponent()
Overrides

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 virtual IDataFlowSource<ETLBoxError> LinkErrorTo(IDataFlowDestination<ETLBoxError> target)
Parameters
TypeNameDescription
IDataFlowDestination<ETLBoxError>target

The target for erroneous rows.

Returns
TypeDescription
IDataFlowSource<ETLBoxError>

The linked component.

Wait()

Waits for the completion of the component.

Declaration
    [Obsolete]
public void Wait()

WriteBatch(TInput[])

Declaration
    protected virtual void WriteBatch(TInput[] data)
Parameters
TypeNameDescription
TInput[]data

Implements