gustavodemorais commented on code in PR #26113:
URL: https://github.com/apache/flink/pull/26113#discussion_r1955968662
##########
docs/content/docs/dev/table/sql/queries/joins.md:
##########
@@ -326,16 +326,55 @@ FROM Orders AS o
In the example above, the Orders table is enriched with data from the
Customers table which resides in a MySQL database. The `FOR SYSTEM_TIME AS OF`
clause with the subsequent processing time attribute ensures that each row of
the `Orders` table is joined with those Customers rows that match the join
predicate at the point in time when the `Orders` row is processed by the join
operator. It also prevents that the join result is updated when a joined
`Customer` row is updated in the future. The lookup join also requires a
mandatory equality join predicate, in the example above `o.customer_id = c.id`.
-Array Expansion
+Array, Multiset and Map Expansion
--------------
-Returns a new row for each element in the given array. Unnesting `WITH
ORDINALITY` is not yet supported.
+Unnest returns a new row for each element in the given array, multiset or map.
Supports both `CROSS JOIN` and `LEFT JOIN`.
+```sql
+-- Returns a new row for each element in a constant array
+SELECT * FROM (VALUES('order_1')), UNNEST(ARRAY["shirt", "pants", "hat"])
Review Comment:
Good catch. I rewrote testUnnestWithValuesStream2 from tests so it's more
user-friendly and messed up the quotes
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
