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
System.Object
LoggableTask
DataFlowComponent
DataFlowSource<System.Dynamic.ExpandoObject>
DataFlowTransformation<System.Dynamic.ExpandoObject, System.Dynamic.ExpandoObject>
Aggregation<System.Dynamic.ExpandoObject, System.Dynamic.ExpandoObject>
Aggregation
Implements
IDataFlowTransformation<System.Dynamic.ExpandoObject, System.Dynamic.ExpandoObject>
IDataFlowSource<System.Dynamic.ExpandoObject>
IDataFlowDestination<System.Dynamic.ExpandoObject>
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 : Aggregation<ExpandoObject, ExpandoObject>, ILoggableTask, IDataFlowLogging, IDataFlowTransformation<ExpandoObject, ExpandoObject>, IDataFlowSource<ExpandoObject>, IDataFlowSource, IDataFlowDestination<ExpandoObject>, IDataFlowDestination, IDataFlowComponent

Constructors

Aggregation(Action<ExpandoObject, ExpandoObject>)

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

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

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

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
Type Name Description
System.Action<System.Dynamic.ExpandoObject, System.Dynamic.ExpandoObject> aggregationAction
System.Func<System.Dynamic.ExpandoObject, System.Object> groupingFunc
System.Action<System.Object, System.Dynamic.ExpandoObject> storeKeyAction

Implements