CachedBatchTransformation

Class CachedBatchTransformation

Inheritance

DataFlowComponent

DataFlowSource<ExpandoObject>

DataFlowTransformation<ExpandoObject, ExpandoObject>

BatchTransformation<ExpandoObject, ExpandoObject>

CachedBatchTransformation<ExpandoObject, ExpandoObject, ExpandoObject>

CachedBatchTransformation<ExpandoObject>

CachedBatchTransformation

Implements

IDataFlowTransformation<ExpandoObject, ExpandoObject>

IDataFlowSource<ExpandoObject>

IDataFlowSource

IDataFlowDestination<ExpandoObject>

IDataFlowDestination

IDataFlowComponent

Inherited Members

CachedBatchTransformation<ExpandoObject, ExpandoObject, ExpandoObject>.BatchTransformationFunc

CachedBatchTransformation<ExpandoObject, ExpandoObject, ExpandoObject>.CacheManager

CachedBatchTransformation<ExpandoObject, ExpandoObject, ExpandoObject>.MaxCacheSize

CachedBatchTransformation<ExpandoObject, ExpandoObject, ExpandoObject>.Reset()

CachedBatchTransformation<ExpandoObject, ExpandoObject, ExpandoObject>.CheckParameter()

CachedBatchTransformation<ExpandoObject, ExpandoObject, ExpandoObject>.InvokeInitActionOnce()

CachedBatchTransformation<ExpandoObject, ExpandoObject, ExpandoObject>.InvokeBatchTransformationFunc(ExpandoObject[])

BatchTransformation<ExpandoObject, ExpandoObject>.SourceBlock

BatchTransformation<ExpandoObject, ExpandoObject>.TargetBlock

BatchTransformation<ExpandoObject, ExpandoObject>.BatchTransformationFunc

BatchTransformation<ExpandoObject, ExpandoObject>.BatchSize

BatchTransformation<ExpandoObject, ExpandoObject>.InitAction

BatchTransformation<ExpandoObject, ExpandoObject>.SuppressNullValueFilter

BatchTransformation<ExpandoObject, ExpandoObject>.WasInitActionInvoked

BatchTransformation<ExpandoObject, ExpandoObject>.Reset()

BatchTransformation<ExpandoObject, ExpandoObject>.CheckParameter()

BatchTransformation<ExpandoObject, ExpandoObject>.CheckAndAdjustBatchSize()

BatchTransformation<ExpandoObject, ExpandoObject>.InitComponent()

BatchTransformation<ExpandoObject, ExpandoObject>.CleanUpOnSuccess()

BatchTransformation<ExpandoObject, ExpandoObject>.CleanUpOnFaulted(Exception)

BatchTransformation<ExpandoObject, ExpandoObject>.InvokeInitActionOnce()

BatchTransformation<ExpandoObject, ExpandoObject>.InvokeBatchTransformationFunc(ExpandoObject[])

DataFlowSource<ExpandoObject>.SourceBlock

DataFlowSource<ExpandoObject>.LinkTo(IDataFlowDestination<ExpandoObject>)

DataFlowSource<ExpandoObject>.LinkTo(IDataFlowDestination<ExpandoObject>, Predicate<ExpandoObject>)

DataFlowSource<ExpandoObject>.LinkTo(IDataFlowDestination<ExpandoObject>, Predicate<ExpandoObject>, Predicate<ExpandoObject>)

DataFlowSource<ExpandoObject>.LinkTo<TConvert>(IDataFlowDestination<ExpandoObject>)

DataFlowSource<ExpandoObject>.LinkTo<TConvert>(IDataFlowDestination<ExpandoObject>, Predicate<ExpandoObject>)

DataFlowSource<ExpandoObject>.LinkTo<TConvert>(IDataFlowDestination<ExpandoObject>, Predicate<ExpandoObject>, Predicate<ExpandoObject>)

DataFlowComponent.MaxBufferSize

DataFlowComponent.Predecessors

DataFlowComponent.Successors

DataFlowComponent.Completion

DataFlowComponent.BufferCancellationSource

DataFlowComponent.BufferCancellationToken

DataFlowComponent.WasComponentInitialized

DataFlowComponent.IsReadyForProcessing

DataFlowComponent.SetParentComponent(DataFlowComponent)

DataFlowComponent.LinkErrorTo(IDataFlowDestination<ETLBoxError>)

DataFlowComponent.InternalLinkTo<T>(IDataFlowDestination, object, object)

DataFlowComponent.AddAutomaticVoidLinkToOtherTargets(DataFlowComponent, IDataFlowDestination)

DataFlowComponent.ResetComponent()

DataFlowComponent.InitBufferObjects(CancellationToken?)

DataFlowComponent.PrepareParameterForCheck()

DataFlowComponent.CheckParameter()

DataFlowComponent.InitCheckedParameter()

DataFlowComponent.InitComponent()

DataFlowComponent.OnInitialization

DataFlowComponent.OnCompletion

DataFlowComponent.OnException

DataFlowComponent.CompleteOrFaultBufferOnPredecessorCompletion(Task)

DataFlowComponent.CleanUpOnSuccess()

DataFlowComponent.CleanUpOnFaulted(Exception)

DataFlowComponent.Exception

DataFlowComponent.ErrorSource

DataFlowComponent.CancelBufferAndThrowOperationCanceledException()

DataFlowComponent.InternalLinkErrorTo(IDataFlowDestination<ETLBoxError>)

DataFlowComponent.ThrowOrRedirectError(Exception, string, string)

DataFlowComponent.ThrowErrorAndFaultNetwork(Exception, string)

DataFlowComponent.CancelComponent()

DataFlowComponent.ErrorCount

DataFlowComponent.ProgressCount

DataFlowComponent.OnProgress

DataFlowComponent.ExecutionStartTime

DataFlowComponent.ExecutionEndTime

DataFlowComponent.Tag

DataFlowComponent.LoggingStartOnce()

DataFlowComponent.LoggingFinishOnce()

DataFlowComponent.LogProgressBatch_AfterThrowOrRedirectError(int)

DataFlowComponent.LogProgress_AfterThrowOrRedirectError()

LoggableTask.TaskType

LoggableTask.TaskName

LoggableTask.DisableLogging

LoggableTask.LogThreshold

LoggableTask.TaskHash

LoggableTask.LogInstance

LoggableTask.ParentTask

LoggableTask.LogTrace(string, params object[])

LoggableTask.LogDebug(string, params object[])

LoggableTask.LogInfo(string, params object[])

LoggableTask.LogInfoOrDebug(string, params object[])

LoggableTask.LogWarn(string, params object[])

LoggableTask.LogError(string, params object[])

LoggableTask.LogFatal(string, params object[])

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 CachedBatchTransformation : CachedBatchTransformation<ExpandoObject>, IDataFlowTransformation<ExpandoObject, ExpandoObject>, IDataFlowSource<ExpandoObject>, IDataFlowSource, IDataFlowDestination<ExpandoObject>, IDataFlowDestination, IDataFlowComponent, ILoggableTask

Constructors

CachedBatchTransformation()

Declaration

    public CachedBatchTransformation()

CachedBatchTransformation(int)

Declaration

    public CachedBatchTransformation(int batchSize)

Parameters

Type	Name	Description
int	batchSize

CachedBatchTransformation(int, Func<ExpandoObject[], CachedData<ExpandoObject>, ExpandoObject[]>)

Declaration

    public CachedBatchTransformation(int batchSize, Func<ExpandoObject[], CachedData<ExpandoObject>, ExpandoObject[]> batchTransformationFunc)

Parameters

Type	Name	Description
int	batchSize
Func<ExpandoObject[], CachedData<ExpandoObject>, ExpandoObject[]>	batchTransformationFunc

Methods

Reset()

Declaration

    protected override void Reset()

Overrides

CachedBatchTransformation<ExpandoObject>.Reset()

Implements

IDataFlowTransformation<TInput, TOutput>

IDataFlowSource<TOutput>

IDataFlowSource

IDataFlowDestination<TInput>

IDataFlowDestination

IDataFlowComponent

Edit this page on GitHub

Prev

CachedBatchTransformation<TInput, TOutput, TCache>

Next

CachedData<TCache>