How to check if spark dataframe is empty?

by

For Spark 2.1.0, my suggestion would be to use head(n: Int) or take(n: Int) with isEmpty, whichever one has the clearest intent to you.

df.head(1).isEmpty
df.take(1).isEmpty

with Python equivalent:

len(df.head(1)) == 0  # or bool(df.head(1))
len(df.take(1)) == 0  # or bool(df.take(1))

Using df.first() and df.head() will both return the java.util.NoSuchElementException if the DataFrame is empty. first() calls head() directly, which calls head(1).head.

def first(): T = head()
def head(): T = head(1).head

head(1) returns an Array, so taking head on that Array causes the java.util.NoSuchElementException when the DataFrame is empty.

def head(n: Int): Array[T] = withAction("head", limit(n).queryExecution)(collectFromPlan)

So instead of calling head(), use head(1) directly to get the array and then you can use isEmpty.

take(n) is also equivalent to head(n)…

def take(n: Int): Array[T] = head(n)

And limit(1).collect() is equivalent to head(1) (notice limit(n).queryExecution in the head(n: Int) method), so the following are all equivalent, at least from what I can tell, and you won’t have to catch a java.util.NoSuchElementException exception when the DataFrame is empty.

df.head(1).isEmpty
df.take(1).isEmpty
df.limit(1).collect().isEmpty

I know this is an older question so hopefully it will help someone using a newer version of Spark.

More Related Contents:

  1. Finding duplicates from large data set using Apache Spark
  2. How to melt Spark DataFrame?
  3. Using a column value as a parameter to a spark DataFrame function
  4. Find maximum row per group in Spark DataFrame
  5. Unpivot in spark-sql/pyspark
  6. Split Spark Dataframe string column into multiple columns
  7. Avoid performance impact of a single partition mode in Spark window functions
  8. How to access element of a VectorUDT column in a Spark DataFrame?
  9. Spark Dataframe validating column names for parquet writes
  10. How to split a list to multiple columns in Pyspark?
  11. pyspark dataframe filter or include based on list
  12. How to save/insert each DStream into a permanent table
  13. Pyspark : forward fill with last observation for a DataFrame
  14. Spark load data and add filename as dataframe column
  15. PySpark: how to resample frequencies
  16. How to loop through each row of dataFrame in pyspark
  17. Fill in null with previously known good value with pyspark
  18. Why does Spark think this is a cross / Cartesian join
  19. PySpark – get row number for each row in a group
  20. How to find count of Null and Nan values for each column in a PySpark dataframe efficiently?
  21. Rename more than one column using withColumnRenamed
  22. Keep only duplicates from a DataFrame regarding some field
  23. pyspark: count distinct over a window
  24. How can I access python variable in Spark SQL?
  25. PySpark: How to fillna values in dataframe for specific columns?
  26. How to exclude multiple columns in Spark dataframe in Python
  27. Stratified sampling with pyspark
  28. How to turn off scientific notation in pyspark?
  29. spark.ml StringIndexer throws ‘Unseen label’ on fit()
  30. PySpark error: AttributeError: ‘NoneType’ object has no attribute ‘_jvm’

Leave a Comment