pyflink.table.expressions.call_sql

call_sql(sql_expression: str) → pyflink.table.expression.Expression

A call to a SQL expression.

The given string is parsed and translated into a Table API expression during planning. Only the translated expression is evaluated during runtime.

Note: Currently, calls are limited to simple scalar expressions. Calls to aggregate or table-valued functions are not supported. Sub-queries are also not allowed.

Parameters

sql_expression – SQL expression to be translated

New in version 1.12.0.