Class DataFlowBatchDestination<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 DataFlowBatchDestination<TInput> : DataFlowDestination<TInput>, ILoggableTask, IDataFlowLogging, IDataFlowBatchDestination<TInput>, IDataFlowDestination<TInput>, IDataFlowDestination, IDataFlowComponent, IDataFlowBatchDestination
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
System.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
System.Int32

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
System.Func<TInput[], TInput[]>

UseBufferBlock

Declaration
    protected override bool UseBufferBlock { get; set; }
Property Value
TypeDescription
System.Boolean
Overrides
ETLBox.DataFlow.DataFlowDestination<TInput>.UseBufferBlock

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
System.Exceptione
Overrides

CleanUpOnSuccess()

Declaration
    protected override void CleanUpOnSuccess()
Overrides

FinishWrite()

Declaration
    protected abstract void FinishWrite()

PrepareWrite()

Declaration
    protected abstract void PrepareWrite()

WriteBatch(TInput[])

Declaration
    protected override void WriteBatch(TInput[] data)
Parameters
TypeNameDescription
TInput[]data
Overrides
ETLBox.DataFlow.DataFlowDestination<TInput>.WriteBatch(TInput[])

Implements