aboutsummaryrefslogtreecommitdiff
path: root/python/pyspark/sql/streaming.py
diff options
context:
space:
mode:
authorAndrew Or <andrew@databricks.com>2016-05-04 17:39:30 -0700
committerAndrew Or <andrew@databricks.com>2016-05-04 17:39:30 -0700
commitfa79d346e1a79ceda6ccd20e74eb850e769556ea (patch)
tree32167c123cbed108caed8773b4985f8918de2b2e /python/pyspark/sql/streaming.py
parentb28137764716f56fa1a923c4278624a56364a505 (diff)
downloadspark-fa79d346e1a79ceda6ccd20e74eb850e769556ea.tar.gz
spark-fa79d346e1a79ceda6ccd20e74eb850e769556ea.tar.bz2
spark-fa79d346e1a79ceda6ccd20e74eb850e769556ea.zip
[SPARK-14896][SQL] Deprecate HiveContext in python
## What changes were proposed in this pull request? See title. ## How was this patch tested? PySpark tests. Author: Andrew Or <andrew@databricks.com> Closes #12917 from andrewor14/deprecate-hive-context-python.
Diffstat (limited to 'python/pyspark/sql/streaming.py')
-rw-r--r--python/pyspark/sql/streaming.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/python/pyspark/sql/streaming.py b/python/pyspark/sql/streaming.py
index bf03fdca91..8238b8e7cd 100644
--- a/python/pyspark/sql/streaming.py
+++ b/python/pyspark/sql/streaming.py
@@ -221,7 +221,7 @@ def _test():
globs['os'] = os
globs['sc'] = sc
globs['sqlContext'] = SQLContext(sc)
- globs['hiveContext'] = HiveContext(sc)
+ globs['hiveContext'] = HiveContext._createForTesting(sc)
globs['df'] = \
globs['sqlContext'].read.format('text').stream('python/test_support/sql/streaming')