DataFlowBatchDestination<TInput>

Class DataFlowBatchDestination<TInput>

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

Properties

AfterBatchWrite

This action is called after a batch was successfully inserted into the destination. You will get a copy of the data that was used for the insertion.

Declaration
    public Action<TInput[]> AfterBatchWrite { get; set; }
Property Value
TypeDescription
Action<TInput[]>

BatchSize

The batch size defines how many records needs to be in the Input buffer before data is written into the destination. The default batch size is 1000.

Declaration
    public int BatchSize { get; set; }
Property Value
TypeDescription
int

BeforeBatchWrite

This function is called every time before a batch is inserted into the destination. It receives an array that represents the batch - you can modify the data itself if needed.

Declaration
    public Func<TInput[], TInput[]> BeforeBatchWrite { get; set; }
Property Value
TypeDescription
Func<TInput[], TInput[]>

UseBufferBlock

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

Methods

BulkInsertData(TInput[])

Declaration
    protected abstract void BulkInsertData(TInput[] data)
Parameters
TypeNameDescription
TInput[]data

CleanUpOnFaulted(Exception)

Declaration
    protected override void CleanUpOnFaulted(Exception e)
Parameters
TypeNameDescription
Exceptione
Overrides

CleanUpOnSuccess()

Declaration
    protected override void CleanUpOnSuccess()
Overrides

FinishWrite()

Declaration
    protected abstract void FinishWrite()

InitComponent()

Declaration
    protected override void InitComponent()
Overrides

PrepareWrite()

Declaration
    protected abstract void PrepareWrite()

WriteBatch(TInput[])

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

Implements