Title here
Summary here
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.
public class CustomBatchDestination<TInput> : DataFlowBatchDestination<TInput>, IDataFlowLogging, IDataFlowBatchDestination<TInput>, IDataFlowDestination<TInput>, IDataFlowBatchDestination, IDataFlowDestination, IDataFlowComponent, ILoggableTask
Name | Description |
---|---|
TInput | Type of ingoing data. |
public CustomBatchDestination()
public CustomBatchDestination(Action<TInput[], int> writeBatchAction)
Type | Name | Description |
---|---|---|
Action<TInput[], int> | writeBatchAction |
public CustomBatchDestination(int batchSize, Action<TInput[], int> writeBatchAction)
Type | Name | Description |
---|---|---|
int | batchSize | |
Action<TInput[], int> | 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.
public Action<TInput[], int> WriteBatchAction { get; set; }
Type | Description |
---|---|
Action<TInput[], int> |
protected override void BulkInsertData(TInput[] data)
Type | Name | Description |
---|---|---|
TInput[] | data |
protected override void CheckParameter()
protected override void FinishWrite()
protected override void PrepareWrite()