Class DataFlowDestination<TInput>

Inherited Members
Namespace: ETLBox.DataFlow
Assembly: ETLBox.dll
Syntax
    public abstract class DataFlowDestination<TInput> : DataFlowComponent, IDataFlowLogging, IDataFlowDestination<TInput>, IDataFlowDestination, IDataFlowComponent, ILoggableTask
Type Parameters
NameDescription
TInput

Fields

Buffer

Declaration
    protected BatchBlock<TInput> Buffer
Field Value
TypeDescription
BatchBlock<TInput>

DEFAULT_BATCH_SIZE

Declaration
    public const int DEFAULT_BATCH_SIZE = 1000
Field Value
TypeDescription
int

InternalBatchSize

Declaration
    protected int InternalBatchSize
Field Value
TypeDescription
int

Properties

BufferTargetAction

Declaration
    protected ActionBlock<TInput[]> BufferTargetAction { get; set; }
Property Value
TypeDescription
ActionBlock<TInput[]>

TargetAction

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

UseBufferBlock

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

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.

WriteBatch(TInput[])

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

Implements