diff options
| author | Liang-Chi Hsieh <simonh@tw.ibm.com> | 2016-06-10 11:05:04 -0700 |
|---|---|---|
| committer | Cheng Lian <lian@databricks.com> | 2016-06-10 11:05:04 -0700 |
| commit | 0ec279ffdf92853965e327a9f0f6956cacb7a23e (patch) | |
| tree | e377cbb45d54717cdbd2471b8868c8dfdd7cc0b9 /sql/hive | |
| parent | abdb5d42c5802c8f60876aa1285c803d02881258 (diff) | |
| download | spark-0ec279ffdf92853965e327a9f0f6956cacb7a23e.tar.gz spark-0ec279ffdf92853965e327a9f0f6956cacb7a23e.tar.bz2 spark-0ec279ffdf92853965e327a9f0f6956cacb7a23e.zip | |
[SPARK-15753][SQL] Move Analyzer stuff to Analyzer from DataFrameWriter
## What changes were proposed in this pull request?
This patch moves some codes in `DataFrameWriter.insertInto` that belongs to `Analyzer`.
## How was this patch tested?
Existing tests.
Author: Liang-Chi Hsieh <simonh@tw.ibm.com>
Closes #13496 from viirya/move-analyzer-stuff.
Diffstat (limited to 'sql/hive')
| -rw-r--r-- | sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveQuerySuite.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveQuerySuite.scala b/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveQuerySuite.scala index e0f6ccf04d..0a2bab4f5d 100644 --- a/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveQuerySuite.scala +++ b/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveQuerySuite.scala @@ -1042,7 +1042,7 @@ class HiveQuerySuite extends HiveComparisonTest with BeforeAndAfter { .queryExecution.analyzed } - assertResult(1, "Duplicated project detected\n" + analyzedPlan) { + assertResult(2, "Duplicated project detected\n" + analyzedPlan) { analyzedPlan.collect { case _: Project => () }.size @@ -1061,7 +1061,7 @@ class HiveQuerySuite extends HiveComparisonTest with BeforeAndAfter { .queryExecution.analyzed } - assertResult(1, "Duplicated project detected\n" + analyzedPlan) { + assertResult(2, "Duplicated project detected\n" + analyzedPlan) { analyzedPlan.collect { case _: Project => () }.size |