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[])