pyflink.table.Table.left_outer_join_lateral

Table.left_outer_join_lateral(table_function_call: Expression | UserDefinedTableFunctionWrapper, join_predicate: Expression[bool] | None = None) → Table

Joins this Table with an user-defined TableFunction. This join is similar to a SQL left outer join but works with a table function. Each row of the table is joined with all rows produced by the table function. If the join does not produce any row, the outer row is padded with nulls.

Example:

>>> t_env.create_java_temporary_system_function("split",
...     "java.table.function.class.name")
>>> from pyflink.table.expressions import *
>>> tab.left_outer_join_lateral(call('split', ' ').alias('b'))

>>> # take all the columns as inputs
>>> @udtf(result_types=[DataTypes.INT(), DataTypes.STRING()])
... def split_row(row: Row):
...     for s in row[1].split(","):
...         yield row[0], s
>>> tab.left_outer_join_lateral(split_row.alias("a", "b"))

Parameters:

• table_function_call – An expression representing a table function call.

• join_predicate – Optional, The join predicate expression string, join ON TRUE if not exist.

Returns:

The result Table.