org.apache.beam.sdk.extensions.sql.impl.interpreter

Class BeamSqlExpressionEnvironments

java.lang.Object

org.apache.beam.sdk.extensions.sql.impl.interpreter.BeamSqlExpressionEnvironments

public class BeamSqlExpressionEnvironments
extends java.lang.Object

Implementations of BeamSqlExpressionEnvironment.

Use of arrays is efficient and safe, as Calcite generates variables densely packed and referenced by index.

Constructor Summary

Constructors

Constructor and Description
BeamSqlExpressionEnvironments()

Method Summary

Modifier and Type	Method and Description
static BeamSqlExpressionEnvironment	empty() An empty environment, for contexts where it is certain there will be no ref access.
static BeamSqlExpressionEnvironment	forRow(Row row, BoundedWindow window) An environment with a fixed row and window but not expressions or correlation variables.
static BeamSqlExpressionEnvironment	forRowAndCorrelVariables(Row row, BoundedWindow window, java.util.List<Row> correlVariables) An environment with a fixed row and window and correlation variables.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BeamSqlExpressionEnvironments

public BeamSqlExpressionEnvironments()

Method Detail

empty

public static BeamSqlExpressionEnvironment empty()

An empty environment, for contexts where it is certain there will be no ref access.

Since there are no expressions, there need not be a row or window.

This environment cannot be extended with local expressions, and will throw UnsupportedOperationException.

forRow

public static BeamSqlExpressionEnvironment forRow(Row row,
                                                  BoundedWindow window)

An environment with a fixed row and window but not expressions or correlation variables.

forRowAndCorrelVariables

public static BeamSqlExpressionEnvironment forRowAndCorrelVariables(Row row,
                                                                    BoundedWindow window,
                                                                    java.util.List<Row> correlVariables)

An environment with a fixed row and window and correlation variables.