( aggregate: AggregateFunction<T, R>, )
| 27 | } |
| 28 | |
| 29 | function isPipedAggregateFunction<T, R>( |
| 30 | aggregate: AggregateFunction<T, R>, |
| 31 | ): aggregate is PipedAggregateFunction<T, R> { |
| 32 | return `pipe` in aggregate |
| 33 | } |
| 34 | |
| 35 | /** |
| 36 | * Groups data by key and applies multiple aggregate operations |