pyflink.table.Table.intersect#

Table.intersect(right: pyflink.table.table.Table) → pyflink.table.table.Table[source]#

Intersects two Table with duplicate records removed. Intersect returns records that exist in both tables. If a record is present in one or both tables more than once, it is returned just once, i.e., the resulting table has no duplicate records. Similar to a SQL INTERSECT. The fields of the two intersect operations must fully overlap.

Note

Both tables must be bound to the same TableEnvironment.

Example:

>>> left.intersect(right)

Parameters: right – Right table.
Returns: The result table.