pyflink.table.expressions.call_sql#
- call_sql(sql_expression: str) Expression[source]#
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
Added in version 1.12.0.