diff options
| author | Burak Yavuz <brkyvz@gmail.com> | 2016-12-15 14:26:54 -0800 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2016-12-15 14:26:54 -0800 |
| commit | 0917c8ee07bd3de87d9754960d8e89808b5efb2f (patch) | |
| tree | 43fac08844a3e1eaff94ad7f2167f655fea7ba18 /python/pyspark/sql/streaming.py | |
| parent | 68a6dc974b25e6eddef109f6fd23ae4e9775ceca (diff) | |
| download | spark-0917c8ee07bd3de87d9754960d8e89808b5efb2f.tar.gz spark-0917c8ee07bd3de87d9754960d8e89808b5efb2f.tar.bz2 spark-0917c8ee07bd3de87d9754960d8e89808b5efb2f.zip | |
[SPARK-18888] partitionBy in DataStreamWriter in Python throws _to_seq not defined
## What changes were proposed in this pull request?
`_to_seq` wasn't imported.
## How was this patch tested?
Added partitionBy to existing write path unit test
Author: Burak Yavuz <brkyvz@gmail.com>
Closes #16297 from brkyvz/SPARK-18888.
Diffstat (limited to 'python/pyspark/sql/streaming.py')
| -rw-r--r-- | python/pyspark/sql/streaming.py | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/python/pyspark/sql/streaming.py b/python/pyspark/sql/streaming.py index eabd5ef54c..5014299ad2 100644 --- a/python/pyspark/sql/streaming.py +++ b/python/pyspark/sql/streaming.py @@ -28,6 +28,7 @@ from abc import ABCMeta, abstractmethod from pyspark import since, keyword_only from pyspark.rdd import ignore_unicode_prefix +from pyspark.sql.column import _to_seq from pyspark.sql.readwriter import OptionUtils, to_str from pyspark.sql.types import * from pyspark.sql.utils import StreamingQueryException |