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.
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
| Type | Name | Description |
|---|---|---|
| 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
| Type | Name | Description |
|---|---|---|
| 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
| Type | Name | Description |
|---|---|---|
| System.Action<T1, T2><ExpandoObject, ExpandoObject> | aggregationAction |