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(BeamRecord inputRow, BoundedWindow window) apply transformation to input record BeamRecord 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(BeamRecord inputRow,
                                         BoundedWindow window)

apply transformation to input record BeamRecord with BoundedWindow.

close

void close()