pyflink.table.Table.join

Table.join(right: Table, join_predicate: Expression[bool] | None = None)

Joins two Table. Similar to a SQL join. The fields of the two joined operations must not overlap, use alias() to rename fields if necessary. You can use where and select clauses after a join to further specify the behaviour of the join.

Note

Both tables must be bound to the same TableEnvironment .

Example:

>>> left.join(right).where((col('a') == col('b')) && (col('c') > 3))
>>> left.join(right, col('a') == col('b'))

Parameters:

• right – Right table.

• join_predicate – Optional, the join predicate expression string.

Returns:

The result table.