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 |
|---|---|
| System.Threading.Tasks.Dataflow.BatchBlock<T><TInput> |
InternalBatchSize
Declaration
protected int InternalBatchSize
Field Value
| Type | Description |
|---|---|
| int |
Properties
BufferTargetAction
Declaration
protected ActionBlock<TInput[]> BufferTargetAction { get; set; }
Property Value
| Type | Description |
|---|---|
| System.Threading.Tasks.Dataflow.ActionBlock<TInput><TInput[]> |
TargetAction
Declaration
protected ActionBlock<TInput> TargetAction { get; set; }
Property Value
| Type | Description |
|---|---|
| System.Threading.Tasks.Dataflow.ActionBlock<TInput><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 |
|---|---|
| System.Threading.Tasks.Dataflow.ITargetBlock<TInput><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. |
Wait()
Waits for the completion of the component.
Declaration
[Obsolete]
public void Wait()
WriteBatch(TInput[])
Declaration
protected virtual void WriteBatch(TInput[] data)
Parameters
| Type | Name | Description |
|---|---|---|
| TInput[] | data |