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 BeamRecord.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.List<BeamSqlExpression>	exps

Constructor Summary

Constructors

Constructor and Description
BeamSqlFnExecutor(BeamRelNode relNode)

Method Summary

Modifier and Type	Method and Description
void	close()
java.util.List<java.lang.Object>	execute(BeamRecord inputRow, BoundedWindow window) apply transformation to input record BeamRecord 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

Field Detail

exps

protected java.util.List<BeamSqlExpression> exps

Constructor Detail

BeamSqlFnExecutor

public BeamSqlFnExecutor(BeamRelNode relNode)

Method Detail

prepare

public void prepare()

Description copied from interface: BeamSqlExpressionExecutor

invoked before data processing.

Specified by:

prepare in interface BeamSqlExpressionExecutor

execute

public java.util.List<java.lang.Object> execute(BeamRecord inputRow,
                                                BoundedWindow window)

Description copied from interface: BeamSqlExpressionExecutor

apply transformation to input record BeamRecord with BoundedWindow.

Specified by:

execute in interface BeamSqlExpressionExecutor

close

public void close()

Specified by:

close in interface BeamSqlExpressionExecutor