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
object
DataFlowDestination<TInput>
MemoryDestination<TInput>
ConcurrentMemoryDestination<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 class ConcurrentMemoryDestination<TInput> : MemoryDestination<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<T><TInput> |
TaskName
Declaration
public override string TaskName { get; set; }
Property Value
| Type | Description |
|---|---|
| string |
Overrides
ETLBox.DataFlow.MemoryDestination<TInput>.TaskName
Methods
AddData(TInput)
Declaration
protected override void AddData(TInput row)
Parameters
| Type | Name | Description |
|---|---|---|
| TInput | row |
Overrides
ETLBox.DataFlow.MemoryDestination<TInput>.AddData(TInput)
CleanUpOnFaulted(Exception)
Declaration
protected override void CleanUpOnFaulted(Exception e)
Parameters
| Type | Name | Description |
|---|---|---|
| System.Exception | e |
Overrides
ETLBox.DataFlow.MemoryDestination<TInput>.CleanUpOnFaulted(System.Exception)
CleanUpOnSuccess()
Declaration
protected override void CleanUpOnSuccess()
Overrides
ETLBox.DataFlow.MemoryDestination<TInput>.CleanUpOnSuccess()