Class Aggregation<TInput, TOutput>

Aggregates data by the given aggregation method.

Inheritance
System.Object
GenericTask
DataFlowTask
DataFlowTransformation<TInput, TOutput>
Aggregation<TInput, TOutput>
Aggregation
Implements
IDataFlowTransformation<TInput, TOutput>
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.Transformations
Assembly: ETLBox.dll
Syntax
public class Aggregation<TInput, TOutput> : DataFlowTransformation<TInput, TOutput>, IDataFlowTransformation<TInput, TOutput>, IDataFlowLinkSource<TOutput>, IDataFlowLinkTarget<TInput>, ITask
Type Parameters
Name Description
TInput

Type of data input
TOutput

Type of data output

Constructors

Aggregation()

Declaration
public Aggregation()

Aggregation(Action<TInput, TOutput>)

Declaration
public Aggregation(Action<TInput, TOutput> aggregationAction)
Parameters
Type Name Description
System.Action<TInput, TOutput> aggregationAction

Aggregation(Action<TInput, TOutput>, Func<TInput, Object>)

Declaration
public Aggregation(Action<TInput, TOutput> aggregationAction, Func<TInput, object> groupingFunc)
Parameters
Type Name Description
System.Action<TInput, TOutput> aggregationAction
System.Func<TInput, System.Object> groupingFunc

Aggregation(Action<TInput, TOutput>, Func<TInput, Object>, Action<Object, TOutput>)

Declaration
public Aggregation(Action<TInput, TOutput> aggregationAction, Func<TInput, object> groupingFunc, Action<object, TOutput> storeKeyAction)
Parameters
Type Name Description
System.Action<TInput, TOutput> aggregationAction
System.Func<TInput, System.Object> groupingFunc
System.Action<System.Object, TOutput> storeKeyAction

Properties

AggregationAction

Declaration
public Action<TInput, TOutput> AggregationAction { get; set; }
Property Value
Type Description
System.Action<TInput, TOutput>

GroupingFunc

Declaration
public Func<TInput, object> GroupingFunc { get; set; }
Property Value
Type Description
System.Func<TInput, System.Object>

SourceBlock

Declaration
public override ISourceBlock<TOutput> SourceBlock { get; }
Property Value
Type Description
System.Threading.Tasks.Dataflow.ISourceBlock<TOutput>
Overrides
ETLBox.DataFlow.DataFlowTransformation<TInput, TOutput>.SourceBlock

StoreKeyAction

Declaration
public Action<object, TOutput> StoreKeyAction { get; set; }
Property Value
Type Description
System.Action<System.Object, TOutput>

TargetBlock

Declaration
public override ITargetBlock<TInput> TargetBlock { get; }
Property Value
Type Description
System.Threading.Tasks.Dataflow.ITargetBlock<TInput>
Overrides
ETLBox.DataFlow.DataFlowTransformation<TInput, TOutput>.TargetBlock

TaskName

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

Implements