Class ConcurrentMemoryDestination<TInput>

A destination in memory - it will store all data in a BlockingCollection<T> The BlockingCollection<T> allows you to access the data concurrently while rows are still written into the target. If you don't need to work with your data before the flow finishes, you can use the MemoryDestination which uses a regular List<T>.

Inheritance
System.Object
ConcurrentMemoryDestination<TInput>
Inherited Members
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.ToString()
Namespace: ETLBox.DataFlow.Connectors
Assembly: ETLBox.dll
Syntax
    public class ConcurrentMemoryDestination<TInput> : MemoryDestination<TInput>, ILoggableTask, IDataFlowLogging, IDataFlowDestination<TInput>, IDataFlowDestination, IDataFlowComponent
Type Parameters
NameDescription
TInput

Type of ingoing data.

Constructors

ConcurrentMemoryDestination()

Declaration
    public ConcurrentMemoryDestination()

Properties

Data

Declaration
    public BlockingCollection<TInput> Data { get; set; }
Property Value
TypeDescription
System.Collections.Concurrent.BlockingCollection<TInput>

TaskName

Declaration
    public override string TaskName { get; set; }
Property Value
TypeDescription
System.String
Overrides
ETLBox.DataFlow.Connectors.MemoryDestination<TInput>.TaskName

Methods

AddData(TInput)

Declaration
    protected override void AddData(TInput row)
Parameters
TypeNameDescription
TInputrow
Overrides
ETLBox.DataFlow.Connectors.MemoryDestination<TInput>.AddData(TInput)

CleanUpOnFaulted(Exception)

Declaration
    protected override void CleanUpOnFaulted(Exception e)
Parameters
TypeNameDescription
System.Exceptione
Overrides
ETLBox.DataFlow.Connectors.MemoryDestination<TInput>.CleanUpOnFaulted(System.Exception)

CleanUpOnSuccess()

Declaration
    protected override void CleanUpOnSuccess()
Overrides
ETLBox.DataFlow.Connectors.MemoryDestination<TInput>.CleanUpOnSuccess()

Implements