pyflink.table.Table.full_outer_join

Table.full_outer_join(right: pyflink.table.table.Table, join_predicate: Union[str, pyflink.table.expression.Expression[bool]]) → pyflink.table.table.Table

Joins two Table. Similar to a SQL full outer join. The fields of the two joined operations must not overlap, use alias() to rename fields if necessary.

Note

Both tables must be bound to the same TableEnvironment and its TableConfig must have null check enabled (default).

Example:

>>> left.full_outer_join(right, col('a') == col('b'))

Parameters

• right – Right table.

• join_predicate – The join predicate expression string.

Returns

The result table.