ETLBox
Title here
Summary here
CachedBatchTransformation<TInput, TOutput>
Class CachedBatchTransformation<TInput, TOutput>
A batch transformation will transform batches of data. The default batch size are 100000 rows. The batch transformation function allows you to process and modify each batch of data. You can use the BatchSize property to choose a smaller batch size. The batch size must always be smaller than the max buffer size. The default batch size are 1000 rows per batch. The batch transformation is a partial blocking transformation - it will always need at least enough memory to store a whole batch.
Inheritance
DataFlowSource<TOutput>
DataFlowTransformation<TInput, TOutput>
BatchTransformation<TInput, TOutput>
CachedBatchTransformation<TInput, TOutput, TInput>
CachedBatchTransformation<TInput, TOutput>
Implements
IDataFlowTransformation<TInput, TOutput>
IDataFlowSource<TOutput>
IDataFlowDestination<TInput>
Inherited Members
Namespace: ETLBox.DataFlow
Assembly: ETLBox.dll
Syntax
public class CachedBatchTransformation<TInput, TOutput> : CachedBatchTransformation<TInput, TOutput, TInput>, IDataFlowTransformation<TInput, TOutput>, IDataFlowSource<TOutput>, IDataFlowSource, IDataFlowDestination<TInput>, IDataFlowDestination, IDataFlowComponent, ILoggableTask where TInput : class
Type Parameters
| Name | Description |
|---|---|
| TInput | Type of ingoing data. |
| TOutput | Type of outgoing data. |
Constructors
CachedBatchTransformation()
Declaration
public CachedBatchTransformation()CachedBatchTransformation(int)
Declaration
public CachedBatchTransformation(int batchSize)Parameters
| Type | Name | Description |
|---|---|---|
| int | batchSize |
CachedBatchTransformation(int, Func<TInput[], CachedData<TInput>, TOutput[]>)
Declaration
public CachedBatchTransformation(int batchSize, Func<TInput[], CachedData<TInput>, TOutput[]> batchTransformationFunc)Parameters
| Type | Name | Description |
|---|---|---|
| int | batchSize | |
| Func<TInput[], CachedData<TInput>, TOutput[]> | batchTransformationFunc |
Methods
Reset()
Declaration
protected override void Reset()