Class DataFlowBatchDestination<TInput>
Inheritance
DataFlowBatchDestination<TInput>
Namespace: ETLBox.DataFlow
Assembly: ETLBox.dll
Syntax
public abstract class DataFlowBatchDestination<TInput> : DataFlowDestination<TInput>, IDataFlowLogging, IDataFlowBatchDestination<TInput>, IDataFlowDestination<TInput>, IDataFlowBatchDestination, IDataFlowDestination, IDataFlowComponent, ILoggableTask
Type Parameters
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
Type | Description |
---|
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
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
Type | Description |
---|
Func<TInput[], TInput[]> | |
UseBufferBlock
Declaration
protected override bool UseBufferBlock { get; set; }
Property Value
Overrides
Methods
BulkInsertData(TInput[])
Declaration
protected abstract void BulkInsertData(TInput[] data)
Parameters
Type | Name | Description |
---|
TInput[] | data | |
CleanUpOnFaulted(Exception)
Declaration
protected override void CleanUpOnFaulted(Exception e)
Parameters
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
Type | Name | Description |
---|
TInput[] | data | |
Overrides
Implements