[BEAM-11872] Support COLLECT operator

• Type: New Feature
• Status: Open
• Priority: P3
• Resolution: Unresolved
• Component/s: dsl-sql
• Assignee: Unassigned
• Reporter: Andrew Pilloud
• Created: 26/Feb/21 02:10
• Updated: 04/Jun/22 19:08

Description

User would like the ARRAY(SELECT ...) operator, which becomes COLLECT.

Simple example:

SELECT ARRAY(SELECT f_int FROM PCOLLECTION)

We also want to make sure the original (more complex) example works:

SELECT
  otherScalarField,
  ARRAY(SELECT row_field1 FROM UNNEST(array_of_nested_rows)
FROM
  table