aboutsummaryrefslogtreecommitdiff
path: root/sql
diff options
context:
space:
mode:
authorJakob Odersky <jakob@odersky.com>2016-02-04 22:22:41 -0800
committerReynold Xin <rxin@databricks.com>2016-02-04 22:22:41 -0800
commit352102ed0b7be8c335553d7e0389fd7ce83f5fbf (patch)
treecac6d85957cf56120f011642df4c0e526dfc7578 /sql
parente3c75c6398b1241500343ff237e9bcf78b5396f9 (diff)
downloadspark-352102ed0b7be8c335553d7e0389fd7ce83f5fbf.tar.gz
spark-352102ed0b7be8c335553d7e0389fd7ce83f5fbf.tar.bz2
spark-352102ed0b7be8c335553d7e0389fd7ce83f5fbf.zip
[SPARK-13208][CORE] Replace use of Pairs with Tuple2s
Another trivial deprecation fix for Scala 2.11 Author: Jakob Odersky <jakob@odersky.com> Closes #11089 from jodersky/SPARK-13208.
Diffstat (limited to 'sql')
-rw-r--r--sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetSchemaSuite.scala2
-rw-r--r--sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveQuerySuite.scala6
2 files changed, 4 insertions, 4 deletions
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetSchemaSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetSchemaSuite.scala
index d860651d42..90e3d50714 100644
--- a/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetSchemaSuite.scala
+++ b/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetSchemaSuite.scala
@@ -261,7 +261,7 @@ class ParquetSchemaInferenceSuite extends ParquetSchemaTest {
int96AsTimestamp = true,
writeLegacyParquetFormat = true)
- testSchemaInference[Tuple1[Pair[Int, String]]](
+ testSchemaInference[Tuple1[(Int, String)]](
"struct",
"""
|message root {
diff --git a/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveQuerySuite.scala b/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveQuerySuite.scala
index 9632d27a2f..1337a25eb2 100644
--- a/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveQuerySuite.scala
+++ b/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveQuerySuite.scala
@@ -770,14 +770,14 @@ class HiveQuerySuite extends HiveComparisonTest with BeforeAndAfter {
test("SPARK-2180: HAVING support in GROUP BY clauses (positive)") {
val fixture = List(("foo", 2), ("bar", 1), ("foo", 4), ("bar", 3))
- .zipWithIndex.map {case Pair(Pair(value, attr), key) => HavingRow(key, value, attr)}
+ .zipWithIndex.map {case ((value, attr), key) => HavingRow(key, value, attr)}
TestHive.sparkContext.parallelize(fixture).toDF().registerTempTable("having_test")
val results =
sql("SELECT value, max(attr) AS attr FROM having_test GROUP BY value HAVING attr > 3")
.collect()
- .map(x => Pair(x.getString(0), x.getInt(1)))
+ .map(x => (x.getString(0), x.getInt(1)))
- assert(results === Array(Pair("foo", 4)))
+ assert(results === Array(("foo", 4)))
TestHive.reset()
}