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
System.Object
CustomBatchDestination<TInput>
Inherited Members
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.ToString()
Namespace: ETLBox.DataFlow.Connectors
Assembly: ETLBox.dll
Syntax
    public class CustomBatchDestination<TInput> : DataFlowBatchDestination<TInput>, ILoggableTask, IDataFlowLogging, IDataFlowBatchDestination<TInput>, IDataFlowBatchDestination, IDataFlowDestination<TInput>, IDataFlowDestination, IDataFlowComponent
Type Parameters
NameDescription
TInput

Type of ingoing data.

Constructors

CustomBatchDestination()

Declaration
    public CustomBatchDestination()

CustomBatchDestination(Action<TInput[], Int32>)

Declaration
    public CustomBatchDestination(Action<TInput[], int> writeBatchAction)
Parameters
TypeNameDescription
System.Action<TInput[], System.Int32>writeBatchAction

Sets the WriteBatchAction

CustomBatchDestination(Int32, Action<TInput[], Int32>)

Declaration
    public CustomBatchDestination(int batchSize, Action<TInput[], int> writeBatchAction)
Parameters
TypeNameDescription
System.Int32batchSize
System.Action<TInput[], System.Int32>writeBatchAction

Sets the 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
TypeDescription
System.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
TypeDescription
System.Action<TInput[], System.Int32>

Methods

BulkInsertData(TInput[])

Declaration
    protected override void BulkInsertData(TInput[] data)
Parameters
TypeNameDescription
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()

Implements