You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@spark.apache.org by "Andreas Maier (JIRA)" <ji...@apache.org> on 2017/11/27 14:52:00 UTC

[jira] [Created] (SPARK-22616) df.cache() / df.persist() should have an option blocking like df.unpersist()

Andreas Maier created SPARK-22616:
-------------------------------------

             Summary: df.cache() / df.persist() should have an option blocking like df.unpersist()
                 Key: SPARK-22616
                 URL: https://issues.apache.org/jira/browse/SPARK-22616
             Project: Spark
          Issue Type: Improvement
          Components: PySpark, Spark Core
    Affects Versions: 2.2.0
            Reporter: Andreas Maier
            Priority: Minor


The method dataframe.unpersist() has an option blocking, which allows for eager unpersisting of a dataframe. On the other side the method dataframe.cache() and dataframe.persist() don't have a comparable option. A (undocumented) workaround for this is to call dataframe.count() directly after cache() or persist(). But for API consistency and convenience it would make sense to give cache() and persist() also the option blocking. 





--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@spark.apache.org
For additional commands, e-mail: issues-help@spark.apache.org