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
object
DataFlowDestination<TInput>
DataFlowBatchDestination<TInput>
CustomBatchDestination<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 class CustomBatchDestination<TInput> : DataFlowBatchDestination<TInput>, ILoggableTask, IDataFlowLogging, IDataFlowBatchDestination<TInput>, IDataFlowDestination<TInput>, IDataFlowBatchDestination, IDataFlowDestination, IDataFlowComponent
Type 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 |
|---|---|---|
| System.Action<T1, T2><TInput[], int> | writeBatchAction |
CustomBatchDestination(int, Action<TInput[], int>)
Declaration
public CustomBatchDestination(int batchSize, Action<TInput[], int> writeBatchAction)
Parameters
| Type | Name | Description |
|---|---|---|
| int | batchSize | |
| System.Action<T1, T2><TInput[], int> | writeBatchAction |
Properties
TaskName
A name to identify the task or component. Every component or task comes with a default name that can be overwritten.
Declaration
public override string TaskName { get; set; }
Property Value
| Type | Description |
|---|---|
| string |
Overrides
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 |
|---|---|
| System.Action<T1, T2><TInput[], int> |
Methods
BulkInsertData(TInput[])
Declaration
protected override void BulkInsertData(TInput[] data)
Parameters
| Type | Name | Description |
|---|---|---|
| TInput[] | data |
Overrides
ETLBox.DataFlow.DataFlowBatchDestination<TInput>.BulkInsertData(TInput[])
CheckParameter()
Declaration
protected override void CheckParameter()
Overrides
FinishWrite()
Declaration
protected override void FinishWrite()
Overrides
ETLBox.DataFlow.DataFlowBatchDestination<TInput>.FinishWrite()
PrepareWrite()
Declaration
protected override void PrepareWrite()
Overrides
ETLBox.DataFlow.DataFlowBatchDestination<TInput>.PrepareWrite()