Package org.apache.beam.sdk.extensions.sql.zetasql.unnest

Temporary solution to support ZetaSQL UNNEST.

See: Description

Class Summary

Class	Description
BeamZetaSqlUncollectRel	BeamRelNode to implement an uncorrelated ZetaSqlUnnest, aka UNNEST.
BeamZetaSqlUncollectRule	A ConverterRule to replace ZetaSqlUnnest with BeamZetaSqlUncollectRel.
BeamZetaSqlUnnestRel	BeamRelNode to implement UNNEST, supporting specifically only Correlate with ZetaSqlUnnest.
BeamZetaSqlUnnestRule	A ConverterRule to replace Correlate ZetaSqlUnnest with BeamZetaSqlUnnestRel.
ZetaSqlUnnest	This class is a copy of Uncollect.java in Calcite: https://github.com/apache/calcite/blob/calcite-1.20.0/core/src/main/java/org/apache/calcite/rel/core/Uncollect.java except that in deriveUncollectRowType() it does not unwrap array elements of struct type.

Package org.apache.beam.sdk.extensions.sql.zetasql.unnest Description

Temporary solution to support ZetaSQL UNNEST. To be removed after Calcite upgrade.