Class DataFlowDestination<TInput>
Inheritance
object
DataFlowDestination<TInput>
Implements
IDataFlowDestination<TInput>
Inherited Members
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 abstract class DataFlowDestination<TInput> : DataFlowComponent, ILoggableTask, IDataFlowLogging, IDataFlowDestination<TInput>, IDataFlowDestination, IDataFlowComponent
Type Parameters
Name | Description |
---|---|
TInput |
Fields
Buffer
Declaration
protected BatchBlock<TInput> Buffer
Field Value
Type | Description |
---|---|
BatchBlock<><TInput> |
DEFAULT_BATCH_SIZE
Declaration
public const int DEFAULT_BATCH_SIZE = 1000
Field Value
Type | Description |
---|---|
int |
InternalBatchSize
Declaration
protected int InternalBatchSize
Field Value
Type | Description |
---|---|
int |
Properties
BufferTargetAction
Declaration
protected ActionBlock<TInput[]> BufferTargetAction { get; set; }
Property Value
Type | Description |
---|---|
ActionBlock<><TInput[]> |
TargetAction
Declaration
protected ActionBlock<TInput> TargetAction { get; set; }
Property Value
Type | Description |
---|---|
ActionBlock<><TInput> |
TargetBlock
TargetBlock from the underlying TPL.Dataflow which is used as output buffer for the component.
Declaration
public ITargetBlock<TInput> TargetBlock { get; }
Property Value
Type | Description |
---|---|
ITargetBlock<><TInput> |
UseBufferBlock
Declaration
protected virtual bool UseBufferBlock { get; set; }
Property Value
Type | Description |
---|---|
bool |
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
Type | Name | Description |
---|---|---|
IDataFlowDestination<ETLBoxError> | target | The target for erroneous rows. |
Returns
Type | Description |
---|---|
IDataFlowSource<ETLBoxError> | The linked component. |
WriteBatch(TInput[])
Declaration
protected virtual void WriteBatch(TInput[] data)
Parameters
Type | Name | Description |
---|---|---|
TInput[] | data |