diff options
Diffstat (limited to 'python/pyspark/sql/session.py')
-rw-r--r-- | python/pyspark/sql/session.py | 11 |
1 files changed, 11 insertions, 0 deletions
diff --git a/python/pyspark/sql/session.py b/python/pyspark/sql/session.py index 7c9f532f94..f0bf0923b8 100644 --- a/python/pyspark/sql/session.py +++ b/python/pyspark/sql/session.py @@ -549,6 +549,17 @@ class SparkSession(object): """ return DataFrameReader(self._wrapped) + @property + @since(2.0) + def streams(self): + """Returns a :class:`ContinuousQueryManager` that allows managing all the + :class:`ContinuousQuery` ContinuousQueries active on `this` context. + + .. note:: Experimental. + """ + from pyspark.sql.streaming import ContinuousQueryManager + return ContinuousQueryManager(self._jsparkSession.streams()) + @since(2.0) def stop(self): """Stop the underlying :class:`SparkContext`. |