diff options
Diffstat (limited to 'python/pyspark/sql/context.py')
-rw-r--r-- | python/pyspark/sql/context.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/python/pyspark/sql/context.py b/python/pyspark/sql/context.py index 486733a390..60f62b219b 100644 --- a/python/pyspark/sql/context.py +++ b/python/pyspark/sql/context.py @@ -433,6 +433,8 @@ class SQLContext(object): 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._ssql_ctx.streams()) |