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, ImmutableMap<java.lang.Integer,java.lang.Object> correlateEnv) 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,
                                         ImmutableMap<java.lang.Integer,java.lang.Object> correlateEnv)

apply transformation to input record Row with BoundedWindow.

close

void close()