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

Interface BeamSqlExpressionExecutor

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

BeamSqlFnExecutor

public interface BeamSqlExpressionExecutor
extends java.io.Serializable

BeamSqlExpressionExecutor fills the gap between relational expressions in Calcite SQL and executable code.

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.

Method Detail

prepare

void prepare()

invoked before data processing.

execute

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

apply transformation to input record Row with BoundedWindow.

close

void close()