Class DataFlowDestination<TInput>
Inheritance
DataFlowDestination<TInput>
Namespace: ETLBox.DataFlow
Assembly: ETLBox.dll
Syntax
public abstract class DataFlowDestination<TInput> : DataFlowComponent, IDataFlowLogging, IDataFlowDestination<TInput>, IDataFlowDestination, IDataFlowComponent, ILoggableTask
Type Parameters
Fields
Buffer
Declaration
protected BatchBlock<TInput> Buffer
Field Value
DEFAULT_BATCH_SIZE
Declaration
public const int DEFAULT_BATCH_SIZE = 1000
Field Value
InternalBatchSize
Declaration
protected int InternalBatchSize
Field Value
Properties
BufferTargetAction
Declaration
protected ActionBlock<TInput[]> BufferTargetAction { get; set; }
Property Value
TargetAction
Declaration
protected ActionBlock<TInput> TargetAction { get; set; }
Property Value
TargetBlock
TargetBlock from the underlying TPL.Dataflow which is used as output buffer for the component.
Declaration
public ITargetBlock<TInput> TargetBlock { get; }
Property Value
UseBufferBlock
Declaration
protected virtual bool UseBufferBlock { get; set; }
Property Value
Methods
InitComponent()
Declaration
protected override void InitComponent()
Overrides
LinkErrorTo(IDataFlowDestination<ETLBoxError>)
If an error occurs in the component, by default the component will throw an exception and stop execution.
If you use the error linking, any erroneous records will catched and redirected.
Declaration
public virtual IDataFlowSource<ETLBoxError> LinkErrorTo(IDataFlowDestination<ETLBoxError> target)
Parameters
Returns
WriteBatch(TInput[])
Declaration
protected virtual void WriteBatch(TInput[] data)
Parameters
Type | Name | Description |
---|
TInput[] | data | |
Implements