ETLBox
Title here
Summary here
CustomBatchDestination<TInput>
Class CustomBatchDestination<TInput>
Define your own batch destination block. This block accepts all data from the flow and will create batches of incoming data which can be processed with the WriteBatchAction.
Inheritance
DataFlowDestination<TInput>
DataFlowBatchDestination<TInput>
CustomBatchDestination<TInput>
Inherited Members
Namespace: ETLBox.DataFlow
Assembly: ETLBox.dll
Syntax
public class CustomBatchDestination<TInput> : DataFlowBatchDestination<TInput>, IDataFlowBatchDestination<TInput>, IDataFlowDestination<TInput>, IDataFlowBatchDestination, IDataFlowDestination, IDataFlowComponent, ILoggableTaskType Parameters
| Name | Description |
|---|---|
| TInput | Type of ingoing data. |
Constructors
CustomBatchDestination()
Declaration
public CustomBatchDestination()CustomBatchDestination(Action<TInput[], int>)
Declaration
public CustomBatchDestination(Action<TInput[], int> writeBatchAction)Parameters
| Type | Name | Description |
|---|---|---|
| Action<TInput[], int> | writeBatchAction |
CustomBatchDestination(int, Action<TInput[], int>)
Declaration
public CustomBatchDestination(int batchSize, Action<TInput[], int> writeBatchAction)Parameters
| Type | Name | Description |
|---|---|---|
| int | batchSize | |
| Action<TInput[], int> | writeBatchAction |
Properties
WriteBatchAction
Each row that the CustomDestination receives is send into this Action as first input value. The second input value is the current progress count.
Declaration
public Action<TInput[], int> WriteBatchAction { get; set; }Property Value
| Type | Description |
|---|---|
| Action<TInput[], int> |
Methods
BulkInsertData(TInput[])
Declaration
protected override void BulkInsertData(TInput[] data)Parameters
| Type | Name | Description |
|---|---|---|
| TInput[] | data |
Overrides
CheckParameter()
Declaration
protected override void CheckParameter()Overrides
FinishWrite()
Declaration
protected override void FinishWrite()Overrides
PrepareWrite()
Declaration
protected override void PrepareWrite()