diff options
author | Michael Armbrust <michael@databricks.com> | 2014-10-24 18:36:35 -0700 |
---|---|---|
committer | Josh Rosen <joshrosen@databricks.com> | 2014-10-24 18:36:35 -0700 |
commit | 3a845d3c048eebb0bddb3937128746fde3e8e4d8 (patch) | |
tree | 192dbba101a08ff02de979efba297587f30fd721 /sql/hive/v0.12.0/src/main/scala | |
parent | 898b22ab1fe90e8a3935b19566465046f2256fa6 (diff) | |
download | spark-3a845d3c048eebb0bddb3937128746fde3e8e4d8.tar.gz spark-3a845d3c048eebb0bddb3937128746fde3e8e4d8.tar.bz2 spark-3a845d3c048eebb0bddb3937128746fde3e8e4d8.zip |
[SQL] Update Hive test harness for Hive 12 and 13
As part of the upgrade I also copy the newest version of the query tests, and whitelist a bunch of new ones that are now passing.
Author: Michael Armbrust <michael@databricks.com>
Closes #2936 from marmbrus/fix13tests and squashes the following commits:
d9cbdab [Michael Armbrust] Remove user specific tests
65801cd [Michael Armbrust] style and rat
8f6b09a [Michael Armbrust] Update test harness to work with both Hive 12 and 13.
f044843 [Michael Armbrust] Update Hive query tests and golden files to 0.13
Diffstat (limited to 'sql/hive/v0.12.0/src/main/scala')
-rw-r--r-- | sql/hive/v0.12.0/src/main/scala/org/apache/spark/sql/hive/Shim12.scala (renamed from sql/hive/v0.12.0/src/main/scala/org/apache/spark/sql/hive/Shim.scala) | 13 |
1 files changed, 10 insertions, 3 deletions
diff --git a/sql/hive/v0.12.0/src/main/scala/org/apache/spark/sql/hive/Shim.scala b/sql/hive/v0.12.0/src/main/scala/org/apache/spark/sql/hive/Shim12.scala index 6dde636965..2317d2e763 100644 --- a/sql/hive/v0.12.0/src/main/scala/org/apache/spark/sql/hive/Shim.scala +++ b/sql/hive/v0.12.0/src/main/scala/org/apache/spark/sql/hive/Shim12.scala @@ -58,9 +58,6 @@ private[hive] object HiveShim { def createDefaultDBIfNeeded(context: HiveContext) = { } - /** The string used to denote an empty comments field in the schema. */ - def getEmptyCommentsFieldValue = "None" - def getCommandProcessor(cmd: Array[String], conf: HiveConf) = { CommandProcessorFactory.get(cmd(0), conf) } @@ -82,6 +79,16 @@ private[hive] object HiveShim { def getAllPartitionsOf(client: Hive, tbl: Table) = client.getAllPartitionsForPruner(tbl) + def compatibilityBlackList = Seq( + "decimal_.*", + "drop_partitions_filter2", + "show_.*", + "serde_regex", + "udf_to_date", + "udaf_collect_set", + "udf_concat" + ) + } class ShimFileSinkDesc(var dir: String, var tableInfo: TableDesc, var compressed: Boolean) |