diff options
| author | Shixiong Zhu <shixiong@databricks.com> | 2016-06-14 02:12:29 -0700 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2016-06-14 02:12:29 -0700 |
| commit | 96c3500c666235f1e746cf17b188930280489d50 (patch) | |
| tree | cad58e884df09481085563b02c0384827ba9d6cd /python/pyspark/sql/context.py | |
| parent | a87a56f5c70792eccbb57046f6b26d40494c380a (diff) | |
| download | spark-96c3500c666235f1e746cf17b188930280489d50.tar.gz spark-96c3500c666235f1e746cf17b188930280489d50.tar.bz2 spark-96c3500c666235f1e746cf17b188930280489d50.zip | |
[SPARK-15935][PYSPARK] Enable test for sql/streaming.py and fix these tests
## What changes were proposed in this pull request?
This PR just enables tests for sql/streaming.py and also fixes the failures.
## How was this patch tested?
Existing unit tests.
Author: Shixiong Zhu <shixiong@databricks.com>
Closes #13655 from zsxwing/python-streaming-test.
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()) |