Skip to content
Snippets Groups Projects
Commit 647aeba3 authored by Yin Huai's avatar Yin Huai Committed by Michael Armbrust
Browse files

[SQL] A tiny refactoring in HiveContext#analyze

I should use `EliminateAnalysisOperators` in  `analyze` instead of manually pattern matching.

Author: Yin Huai <huaiyin.thu@gmail.com>

Closes #1881 from yhuai/useEliminateAnalysisOperators and squashes the following commits:

f3e1e7f [Yin Huai] Use EliminateAnalysisOperators.
parent e83fdcd4
No related branches found
No related tags found
No related merge requests found
......@@ -39,7 +39,8 @@ import org.apache.spark.SparkContext
import org.apache.spark.rdd.RDD
import org.apache.spark.sql._
import org.apache.spark.sql.catalyst.ScalaReflection
import org.apache.spark.sql.catalyst.analysis.{OverrideFunctionRegistry, Analyzer, OverrideCatalog}
import org.apache.spark.sql.catalyst.analysis.{Analyzer, EliminateAnalysisOperators}
import org.apache.spark.sql.catalyst.analysis.{OverrideCatalog, OverrideFunctionRegistry}
import org.apache.spark.sql.catalyst.plans.logical._
import org.apache.spark.sql.execution.ExtractPythonUdfs
import org.apache.spark.sql.execution.QueryExecutionException
......@@ -119,10 +120,7 @@ class HiveContext(sc: SparkContext) extends SQLContext(sc) {
* in the Hive metastore.
*/
def analyze(tableName: String) {
val relation = catalog.lookupRelation(None, tableName) match {
case LowerCaseSchema(r) => r
case o => o
}
val relation = EliminateAnalysisOperators(catalog.lookupRelation(None, tableName))
relation match {
case relation: MetastoreRelation => {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment