Class DataFlowBatchDestination<TInput>
Inherited Members
object.Equals(object)
object.Equals(object, object)
object.GetHashCode()
object.GetType()
object.MemberwiseClone()
object.ReferenceEquals(object, object)
object.ToString()
Namespace: ETLBox.DataFlow
Assembly: ETLBox.dll
Syntax
public abstract class DataFlowBatchDestination<TInput> : DataFlowDestination<TInput>, ILoggableTask, IDataFlowLogging, IDataFlowBatchDestination<TInput>, IDataFlowDestination<TInput>, IDataFlowBatchDestination, IDataFlowDestination, IDataFlowComponent
Type Parameters
| Name | Description |
|---|---|
| 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
| Type | Description |
|---|---|
| System.Action<T><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
| Type | Description |
|---|---|
| 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
| Type | Description |
|---|---|
| System.Func<T, TResult><TInput[], TInput[]> |
UseBufferBlock
Declaration
protected override bool UseBufferBlock { get; set; }
Property Value
| Type | Description |
|---|---|
| bool |
Overrides
ETLBox.DataFlow.DataFlowDestination<TInput>.UseBufferBlock
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
| Type | Name | Description |
|---|---|---|
| System.Exception | e |
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
| Type | Name | Description |
|---|---|---|
| TInput[] | data |
Overrides
ETLBox.DataFlow.DataFlowDestination<TInput>.WriteBatch(TInput[])