Title here
Summary here
public class CachedRowTransformation<TInput, TOutput, TCache> : RowTransformation<TInput, TOutput>, IDataFlowTransformation<TInput, TOutput>, IDataFlowSource<TOutput>, IDataFlowSource, IDataFlowDestination<TInput>, IDataFlowDestination, IDataFlowComponent, ILoggableTask where TCache : class
Name | Description |
---|---|
TInput | |
TOutput | |
TCache |
public CachedRowTransformation()
public CachedRowTransformation(Func<TInput, CachedData<TCache>, TOutput> transformationFunc)
Type | Name | Description |
---|---|---|
Func<TInput, CachedData<TCache>, TOutput> | transformationFunc | Will set the TransformationFunc |
The CacheManager used for caching data
public ICacheManager<TInput, TCache> CacheManager { get; set; }
Type | Description |
---|---|
ICacheManager<TInput, TCache> |
If set to true, the incoming row will be added to the cache after the transformation func has been invoked.
public bool FillCacheAfterTransformation { get; set; }
Type | Description |
---|---|
bool |
The maximum amount of records to store in the cache - this number will only be used if the cache manager supports limiting the cache size.
public int MaxCacheSize { get; set; }
Type | Description |
---|---|
int |
public Func<TInput, CachedData<TCache>, TOutput> TransformationFunc { get; set; }
Type | Description |
---|---|
Func<TInput, CachedData<TCache>, TOutput> |
protected override void CheckParameter()
protected override void InvokeInitActionOnce()
protected override TOutput InvokeTransformationFunc(TInput row)
Type | Name | Description |
---|---|---|
TInput | row |
Type | Description |
---|---|
TOutput |
protected override void Reset()