Class Aggregation

Aggregates data by the given aggregation methods. The aggregate is a partial-blocking transformation - only the aggregation values are stored in separate memory objects. When all rows have been processed by the aggregation, the aggregated values are written into the output.

Inheritance
object
DataFlowSource<ExpandoObject>
DataFlowTransformation<ExpandoObject, ExpandoObject>
Aggregation<ExpandoObject, ExpandoObject>
Aggregation
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 Aggregation : Aggregation<ExpandoObject, ExpandoObject>, ILoggableTask, IDataFlowLogging, IDataFlowTransformation<ExpandoObject, ExpandoObject>, IDataFlowSource<ExpandoObject>, IDataFlowSource, IDataFlowDestination<ExpandoObject>, IDataFlowDestination, IDataFlowComponent

Constructors

Aggregation()

Declaration
    public Aggregation()

Aggregation(Action<ExpandoObject, ExpandoObject>, Func<ExpandoObject, object>, Action<object, ExpandoObject>)

Declaration
    public Aggregation(Action<ExpandoObject, ExpandoObject> aggregationAction, Func<ExpandoObject, object> groupingFunc, Action<object, ExpandoObject> storeKeyAction)
Parameters
TypeNameDescription
System.Action<T1, T2><ExpandoObject, ExpandoObject>aggregationAction
System.Func<T, TResult><ExpandoObject, object>groupingFunc
System.Action<T1, T2><object, ExpandoObject>storeKeyAction

Aggregation(Action<ExpandoObject, ExpandoObject>, Func<ExpandoObject, object>)

Declaration
    public Aggregation(Action<ExpandoObject, ExpandoObject> aggregationAction, Func<ExpandoObject, object> groupingFunc)
Parameters
TypeNameDescription
System.Action<T1, T2><ExpandoObject, ExpandoObject>aggregationAction
System.Func<T, TResult><ExpandoObject, object>groupingFunc

Aggregation(Action<ExpandoObject, ExpandoObject>)

Declaration
    public Aggregation(Action<ExpandoObject, ExpandoObject> aggregationAction)
Parameters
TypeNameDescription
System.Action<T1, T2><ExpandoObject, ExpandoObject>aggregationAction

Implements