pyflink.table.Table.join

Table.join(right: pyflink.table.table.Table, join_predicate: Optional[pyflink.table.expression.Expression[bool]] = 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.