Enum RowAggregationFunction

Specifies which row-based aggregation function to use, such as First, Single etc., with or without grouping. Also see the examples in Dataflow Aggregations.

Without grouping, the function applies to all incoming rows: AggregateTransform1<TInputAccumulateOutput>(in DownstreamFactory<TInputAccumulateOutput>, String, RowAggregationFunction).

With grouping, the function applies to all rows in each grouping: AggregateTransform1<TInputAccumulateOutput>(in DownstreamFactory<TInputAccumulateOutput>, String, RowAggregationFunction, Action<IGroupByCommand>) and AggregateTransform1<TInputAccumulateOutput>(in DownstreamFactory<TInputAccumulateOutput>, String, RowAggregationFunction, IEqualityComparer<TInputAccumulateOutput>).

All these row-based aggregation functions operate without accessing individual columns in the dataflow rows. Use other AggregateTransformFactory overloads to calculate column aggregations (Sum, Average etc.), or any custom aggregation functions.

Namespace: actionETL

Assembly: actionETL.dll

Syntax

public enum RowAggregationFunction

Fields

Name	Description
First	Pass on only the first incoming row. Without grouping, fail the worker with an Error status if there are no incoming rows.
FirstOrNone	Pass on only the first incoming row, if any.
Last	Pass on only the last incoming row. Without grouping, fail the worker with an Error status if there are no incoming rows.
LastOrNone	Pass on only the last incoming row, if any.
None	Complete the worker successfully if there are no incoming rows, or fail the worker with an Error status if there are any incoming rows.
Single	Pass on the single incoming row, or fail the worker with an Error status if there are more than one incoming rows. Without grouping, also fail the worker with an Error status if there are no incoming rows.
SingleOrNone	Pass on the single incoming row, if any, or fail the worker with an Error status if there are more than one incoming rows.

See Also

AggregateTransform1<TInputAccumulateOutput>(DownstreamFactory<TInputAccumulateOutput>, String, RowAggregationFunction)

AggregateTransform1<TInputAccumulateOutput>(DownstreamFactory<TInputAccumulateOutput>, String, RowAggregationFunction, Action<IGroupByCommand>)

AggregateTransform1<TInputAccumulateOutput>(DownstreamFactory<TInputAccumulateOutput>, String, RowAggregationFunction, IEqualityComparer<TInputAccumulateOutput>)