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

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

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

Related Packages

Package	Description
org.apache.beam.sdk.extensions.sql.zetasql	Deprecated. Use Calcite SQL dialect.
org.apache.beam.sdk.extensions.sql.zetasql.translation	Conversion logic between ZetaSQL resolved query nodes and Calcite rel nodes.

Classes

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.