aboutsummaryrefslogtreecommitdiff
path: root/sql/hive
diff options
context:
space:
mode:
authorPatrick Wendell <patrick@databricks.com>2015-05-20 13:39:04 -0700
committerPatrick Wendell <patrick@databricks.com>2015-05-20 13:39:04 -0700
commit6338c40da61de045485c51aa11a5b1e425d22144 (patch)
tree405740ab6ec1f9c7ebfcba73912c8ee042593b9c /sql/hive
parent829f1d95bac9153e7b646fbc0d55566ecf896200 (diff)
downloadspark-6338c40da61de045485c51aa11a5b1e425d22144.tar.gz
spark-6338c40da61de045485c51aa11a5b1e425d22144.tar.bz2
spark-6338c40da61de045485c51aa11a5b1e425d22144.zip
Revert "[SPARK-7320] [SQL] Add Cube / Rollup for dataframe"
This reverts commit 10698e1131f665addb454cd498669920699a91b2.
Diffstat (limited to 'sql/hive')
-rw-r--r--sql/hive/src/test/scala/org/apache/spark/sql/hive/HiveDataFrameAnalyticsSuite.scala62
1 files changed, 0 insertions, 62 deletions
diff --git a/sql/hive/src/test/scala/org/apache/spark/sql/hive/HiveDataFrameAnalyticsSuite.scala b/sql/hive/src/test/scala/org/apache/spark/sql/hive/HiveDataFrameAnalyticsSuite.scala
deleted file mode 100644
index 3ad05f4825..0000000000
--- a/sql/hive/src/test/scala/org/apache/spark/sql/hive/HiveDataFrameAnalyticsSuite.scala
+++ /dev/null
@@ -1,62 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.spark.sql.hive
-
-import org.apache.spark.sql.QueryTest
-import org.apache.spark.sql.functions._
-import org.apache.spark.sql.hive.test.TestHive
-import org.apache.spark.sql.hive.test.TestHive._
-import org.apache.spark.sql.hive.test.TestHive.implicits._
-
-case class TestData2Int(a: Int, b: Int)
-
-// TODO ideally we should put the test suite into the package `sql`, as
-// `hive` package is optional in compiling, however, `SQLContext.sql` doesn't
-// support the `cube` or `rollup` yet.
-class HiveDataFrameAnalyticsSuite extends QueryTest {
- val testData =
- TestHive.sparkContext.parallelize(
- TestData2Int(1, 2) ::
- TestData2Int(2, 4) :: Nil).toDF()
-
- testData.registerTempTable("mytable")
-
- test("rollup") {
- checkAnswer(
- testData.rollup($"a" + $"b", $"b").agg(sum($"a" - $"b")),
- sql("select a + b, b, sum(a - b) from mytable group by a + b, b with rollup").collect()
- )
-
- checkAnswer(
- testData.rollup("a", "b").agg(sum("b")),
- sql("select a, b, sum(b) from mytable group by a, b with rollup").collect()
- )
- }
-
- test("cube") {
- checkAnswer(
- testData.cube($"a" + $"b", $"b").agg(sum($"a" - $"b")),
- sql("select a + b, b, sum(a - b) from mytable group by a + b, b with cube").collect()
- )
-
- checkAnswer(
- testData.cube("a", "b").agg(sum("b")),
- sql("select a, b, sum(b) from mytable group by a, b with cube").collect()
- )
- }
-}