Set[Row].collect()
> println(results.mkString("\n"))
>
> // Result
> 0,1,2
> 1,2,3
> 2,3,4
>
> Best, Fabian
>
> [1] https://ci.apache.org/projects/flink/flink-docs-
> release-1.2/dev/table_api.html
> [2] https://ci.apache.org/projects/flink/flink-docs
The documentation seems to indicate that there is a flatten method
available in the sql language interface (in the table of available
methods), or, alternatively using the '*' character somehow (in the text
above the table).
Yet I cannot flatten a POJO type, nor can I find any sufficient
documenta