From 1161338ad9a103d6da0ae546d2cba0ea4b3986a6 Mon Sep 17 00:00:00 2001 From: Michael Armbrust Date: Wed, 6 Aug 2014 17:30:20 -0700 Subject: [PATCH] Add a test to make sure conversion is actually happening --- .../spark/sql/parquet/ParquetMetastoreSuite.scala | 12 ++++++++++++ 1 file changed, 12 insertions(+) diff --git a/sql/hive/src/test/scala/org/apache/spark/sql/parquet/ParquetMetastoreSuite.scala b/sql/hive/src/test/scala/org/apache/spark/sql/parquet/ParquetMetastoreSuite.scala index 3494c2fd14c29..e5d76c8d71b48 100644 --- a/sql/hive/src/test/scala/org/apache/spark/sql/parquet/ParquetMetastoreSuite.scala +++ b/sql/hive/src/test/scala/org/apache/spark/sql/parquet/ParquetMetastoreSuite.scala @@ -20,6 +20,7 @@ package org.apache.spark.sql.parquet import java.io.File +import org.apache.spark.sql.hive.execution.HiveTableScan import org.scalatest.BeforeAndAfterAll import scala.reflect.ClassTag @@ -123,4 +124,15 @@ class ParquetMetastoreSuite extends QueryTest with BeforeAndAfterAll { 10 ) } + + test("conversion is working") { + assert( + sql("SELECT * FROM normal_parquet").queryExecution.executedPlan.collect { + case _: HiveTableScan => true + }.isEmpty) + assert( + sql("SELECT * FROM normal_parquet").queryExecution.executedPlan.collect { + case _: ParquetTableScan => true + }.nonEmpty) + } }