pyflink.dataframe.DataFrame.minus_all

DataFrame.minus_all(other: pyflink.dataframe.dataframe.DataFrame) → pyflink.dataframe.dataframe.DataFrame

Return rows from this DataFrame that do not exist in another DataFrame.

Duplicate rows are preserved according to SQL EXCEPT ALL semantics.

Schema compatibility is checked by column position, not by column name. Each pair of columns must be castable to a common type. The result uses this DataFrame’s column names and the common types.

Note

This operation is only supported in batch mode.

Parameters

other – Right DataFrame.

Returns

A new DataFrame containing rows from the left side only.