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

Class BeamSqlFnExecutor

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable, BeamSqlExpressionExecutor

public class BeamSqlFnExecutor
extends java.lang.Object
implements BeamSqlExpressionExecutor

Executor based on BeamSqlExpression and BeamSqlPrimitive. BeamSqlFnExecutor converts a BeamRelNode to a BeamSqlExpression, which can be evaluated against the Row.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
BeamSqlFnExecutor(org.apache.calcite.rex.RexProgram program)

Method Summary

Modifier and Type	Method and Description
void	close()
java.util.List<java.lang.Object>	execute(Row inputRow, BoundedWindow window, BeamSqlExpressionEnvironment env) apply transformation to input record Row with BoundedWindow.
void	prepare() invoked before data processing.

Methods inherited from class java.lang.Object

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

Constructor Detail

BeamSqlFnExecutor

public BeamSqlFnExecutor(org.apache.calcite.rex.RexProgram program)

Method Detail

prepare

public void prepare()

Description copied from interface: BeamSqlExpressionExecutor

invoked before data processing.

Specified by:

prepare in interface BeamSqlExpressionExecutor

execute

@Nullable
public java.util.List<java.lang.Object> execute(Row inputRow,
                                                          BoundedWindow window,
                                                          BeamSqlExpressionEnvironment env)

Description copied from interface: BeamSqlExpressionExecutor

apply transformation to input record Row with BoundedWindow.

Specified by:

execute in interface BeamSqlExpressionExecutor

close

public void close()

Specified by:

close in interface BeamSqlExpressionExecutor