diff options
author | Reynold Xin <rxin@databricks.com> | 2016-04-22 22:50:32 -0700 |
---|---|---|
committer | Reynold Xin <rxin@databricks.com> | 2016-04-22 22:50:32 -0700 |
commit | 95faa731c15ce2e36373071a405207165818df97 (patch) | |
tree | f980422766b7bec11314378ee3c8c6748cfc4a47 /sql/catalyst/src | |
parent | bdde010edbc79e506e183e2b9a2b9b19f7b226fb (diff) | |
download | spark-95faa731c15ce2e36373071a405207165818df97.tar.gz spark-95faa731c15ce2e36373071a405207165818df97.tar.bz2 spark-95faa731c15ce2e36373071a405207165818df97.zip |
[SPARK-14866][SQL] Break SQLQuerySuite out into smaller test suites
## What changes were proposed in this pull request?
This patch breaks SQLQuerySuite out into smaller test suites. It was a little bit too large for debugging.
## How was this patch tested?
This is a test only change.
Author: Reynold Xin <rxin@databricks.com>
Closes #12630 from rxin/SPARK-14866.
Diffstat (limited to 'sql/catalyst/src')
-rw-r--r-- | sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala index 182e459d8f..24558d5b8c 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala @@ -407,7 +407,7 @@ class Analyzer( * Replaces [[UnresolvedRelation]]s with concrete relations from the catalog. */ object ResolveRelations extends Rule[LogicalPlan] { - private def getTable(u: UnresolvedRelation): LogicalPlan = { + private def lookupTableFromCatalog(u: UnresolvedRelation): LogicalPlan = { try { catalog.lookupRelation(u.tableIdentifier, u.alias) } catch { @@ -418,10 +418,10 @@ class Analyzer( def apply(plan: LogicalPlan): LogicalPlan = plan resolveOperators { case i @ InsertIntoTable(u: UnresolvedRelation, _, _, _, _) => - i.copy(table = EliminateSubqueryAliases(getTable(u))) + i.copy(table = EliminateSubqueryAliases(lookupTableFromCatalog(u))) case u: UnresolvedRelation => try { - getTable(u) + lookupTableFromCatalog(u) } catch { case _: AnalysisException if u.tableIdentifier.database.isDefined => // delay the exception into CheckAnalysis, then it could be resolved as data source. |