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
LoggableTask
DataFlowComponent
DataFlowDestination<TInput>
ConcurrentMemoryDestination<TInput>
ConcurrentMemoryDestination
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> : DataFlowDestination<TInput>, ILoggableTask, IDataFlowLogging, IDataFlowDestination<TInput>, IDataFlowDestination, IDataFlowComponent
Type Parameters
Name Description
TInput

Type of ingoing data.

Constructors

ConcurrentMemoryDestination()

Declaration
public ConcurrentMemoryDestination()

Properties

Data

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

TaskName

Declaration
public override string TaskName { get; }
Property Value
Type Description
System.String
Overrides

Methods

CleanUpOnFaulted(Exception)

Declaration
protected override void CleanUpOnFaulted(Exception e)
Parameters
Type Name Description
System.Exception e
Overrides

CleanUpOnSuccess()

Declaration
protected override void CleanUpOnSuccess()
Overrides

InternalInitBufferObjects()

Declaration
protected override void InternalInitBufferObjects()
Overrides

WriteRecord(TInput)

Declaration
protected void WriteRecord(TInput row)
Parameters
Type Name Description
TInput row

Implements