diff options
author | Tathagata Das <tathagata.das1565@gmail.com> | 2016-06-15 10:46:02 -0700 |
---|---|---|
committer | Shixiong Zhu <shixiong@databricks.com> | 2016-06-15 10:46:07 -0700 |
commit | 9a5071996b968148f6b9aba12e0d3fe888d9acd8 (patch) | |
tree | 1f39691de83edb31dca56d6cd460261070504248 /python/pyspark/sql/utils.py | |
parent | d30b7e6696e20f1014c7f26aadbc051da0fac578 (diff) | |
download | spark-9a5071996b968148f6b9aba12e0d3fe888d9acd8.tar.gz spark-9a5071996b968148f6b9aba12e0d3fe888d9acd8.tar.bz2 spark-9a5071996b968148f6b9aba12e0d3fe888d9acd8.zip |
[SPARK-15953][WIP][STREAMING] Renamed ContinuousQuery to StreamingQuery
Renamed for simplicity, so that its obvious that its related to streaming.
Existing unit tests.
Author: Tathagata Das <tathagata.das1565@gmail.com>
Closes #13673 from tdas/SPARK-15953.
Diffstat (limited to 'python/pyspark/sql/utils.py')
-rw-r--r-- | python/pyspark/sql/utils.py | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/python/pyspark/sql/utils.py b/python/pyspark/sql/utils.py index 9ddaf78acf..2a85ec01bc 100644 --- a/python/pyspark/sql/utils.py +++ b/python/pyspark/sql/utils.py @@ -45,9 +45,9 @@ class IllegalArgumentException(CapturedException): """ -class ContinuousQueryException(CapturedException): +class StreamingQueryException(CapturedException): """ - Exception that stopped a :class:`ContinuousQuery`. + Exception that stopped a :class:`StreamingQuery`. """ @@ -71,8 +71,8 @@ def capture_sql_exception(f): raise AnalysisException(s.split(': ', 1)[1], stackTrace) if s.startswith('org.apache.spark.sql.catalyst.parser.ParseException: '): raise ParseException(s.split(': ', 1)[1], stackTrace) - if s.startswith('org.apache.spark.sql.streaming.ContinuousQueryException: '): - raise ContinuousQueryException(s.split(': ', 1)[1], stackTrace) + if s.startswith('org.apache.spark.sql.streaming.StreamingQueryException: '): + raise StreamingQueryException(s.split(': ', 1)[1], stackTrace) if s.startswith('org.apache.spark.sql.execution.QueryExecutionException: '): raise QueryExecutionException(s.split(': ', 1)[1], stackTrace) if s.startswith('java.lang.IllegalArgumentException: '): |