|
17 | 17 |
|
18 | 18 | package org.apache.spark.sql.hive.execution
|
19 | 19 |
|
20 |
| -import org.scalatest.{BeforeAndAfterAll, FunSuite} |
21 |
| - |
22 |
| -import org.apache.spark.{SparkConf, SparkContext} |
23 |
| -import org.apache.spark.sql.hive.test.TestHive |
24 |
| - |
25 | 20 | class HiveTableScanSuite extends HiveComparisonTest {
|
26 |
| - // MINOR HACK: You must run a query before calling reset the first time. |
27 |
| - TestHive.hql("SHOW TABLES") |
28 |
| - TestHive.reset() |
29 |
| - |
30 |
| - TestHive.hql("""CREATE TABLE part_scan_test (key STRING, value STRING) PARTITIONED BY (ds STRING) |
31 |
| - | ROW FORMAT SERDE |
32 |
| - | 'org.apache.hadoop.hive.serde2.columnar.LazyBinaryColumnarSerDe' |
33 |
| - | STORED AS RCFILE |
34 |
| - """.stripMargin) |
35 |
| - TestHive.hql("""FROM src |
36 |
| - | INSERT INTO TABLE part_scan_test PARTITION (ds='2010-01-01') |
37 |
| - | SELECT 100,100 LIMIT 1 |
38 |
| - """.stripMargin) |
39 |
| - TestHive.hql("""ALTER TABLE part_scan_test SET SERDE |
40 |
| - | 'org.apache.hadoop.hive.serde2.columnar.ColumnarSerDe' |
41 |
| - """.stripMargin) |
42 |
| - TestHive.hql("""FROM src INSERT INTO TABLE part_scan_test PARTITION (ds='2010-01-02') |
43 |
| - | SELECT 200,200 LIMIT 1 |
44 |
| - """.stripMargin) |
45 | 21 |
|
46 |
| - createQueryTest("partition_based_table_scan_with_different_serde", |
47 |
| - "SELECT * from part_scan_test", false) |
| 22 | + createQueryTest("partition_based_table_scan_with_different_serde", |
| 23 | + """ |
| 24 | + |CREATE TABLE part_scan_test (key STRING, value STRING) PARTITIONED BY (ds STRING) |
| 25 | + |ROW FORMAT SERDE |
| 26 | + |'org.apache.hadoop.hive.serde2.columnar.LazyBinaryColumnarSerDe' |
| 27 | + |STORED AS RCFILE; |
| 28 | + | |
| 29 | + |FROM src |
| 30 | + |INSERT INTO TABLE part_scan_test PARTITION (ds='2010-01-01') |
| 31 | + |SELECT 100,100 LIMIT 1; |
| 32 | + | |
| 33 | + |ALTER TABLE part_scan_test SET SERDE |
| 34 | + |'org.apache.hadoop.hive.serde2.columnar.ColumnarSerDe'; |
| 35 | + | |
| 36 | + |FROM src INSERT INTO TABLE part_scan_test PARTITION (ds='2010-01-02') |
| 37 | + |SELECT 200,200 LIMIT 1; |
| 38 | + | |
| 39 | + |SELECT * from part_scan_test; |
| 40 | + """.stripMargin) |
48 | 41 | }
|
0 commit comments