22 lines (16 loc) · 981 Bytes

Phase 9e: Array Aggregations (Completed)

Status: Completed (2025-12-22)

This phase added support for collecting values into lists and sets during aggregation, enabling data denormalization directly within the pipeline.

Delivered Features

1. New Aggregation Operations

collect_list(Field, Result): Collects all values into a list (preserving duplicates).
- Implementation: Go slice ([]interface{}).
- Appends values efficiently.
collect_set(Field, Result): Collects unique values into a list (deduplicated).
- Implementation: Go map (map[interface{}]bool).
- O(1) insertion, converts to slice for output.

2. Integration

Fully integrated with group_by/4 and multiple aggregation lists.
Compatible with other statistical and simple aggregations (e.g., [count(N), collect_list(Tags, T)]).

Verification

tests/test_go_array_agg.pl: Verified correct Go code generation for list appending and set map management/conversion.