_utils#

Private utility functions.

Functions#

assert_is_identifier()

Check that the given identifier is a valid table name.

dataframe_is_empty()

Checks if a pyspark dataframe is empty.

assert_is_identifier(identifier)#

Check that the given identifier is a valid table name.

Parameters

identifier (str) –

dataframe_is_empty(df)#

Checks if a pyspark dataframe is empty.

Will use the more efficient DataFrame.isEmpty() method if it’s available (i.e. if pySpark > 3.3.0).

Parameters

df (pyspark.sql.DataFrame) –

Return type

bool