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

Interface BeamSqlExpressionEnvironment

public interface BeamSqlExpressionEnvironment

Environment in which a BeamSqlExpression is evaluated. This includes bindings of correlation variables and local references.

Method Summary

Modifier and Type	Method and Description
BeamSqlExpressionEnvironment	copyWithLocalRefExprs(java.util.List<BeamSqlExpression> localRefExprs) An environment that shares input row, window, and correlation variables but local refs are replaced with the given unevaluated expressions.
Row	getCorrelVariable(int correlVariableId) Gets the value for a correlation variable.
BeamSqlPrimitive<?>	getLocalRef(int localRefIndex) Gets the value for a local variable reference.

Method Detail

getLocalRef

BeamSqlPrimitive<?> getLocalRef(int localRefIndex)

Gets the value for a local variable reference.

getCorrelVariable

Row getCorrelVariable(int correlVariableId)

Gets the value for a correlation variable.

copyWithLocalRefExprs

BeamSqlExpressionEnvironment copyWithLocalRefExprs(java.util.List<BeamSqlExpression> localRefExprs)

An environment that shares input row, window, and correlation variables but local refs are replaced with the given unevaluated expressions.