diff options
| author | CodingCat <zhunansjtu@gmail.com> | 2016-09-03 10:03:40 +0100 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2016-09-03 10:03:40 +0100 |
| commit | 97da41039b2b8fa7f93caf213ae45b9973925995 (patch) | |
| tree | 0a589ce32bba8ea301d072729f0d876c3b842193 /examples | |
| parent | 7a8a81d79f4bee3395fb399ccc4d47744f8a0951 (diff) | |
| download | spark-97da41039b2b8fa7f93caf213ae45b9973925995.tar.gz spark-97da41039b2b8fa7f93caf213ae45b9973925995.tar.bz2 spark-97da41039b2b8fa7f93caf213ae45b9973925995.zip | |
[SPARK-17347][SQL][EXAMPLES] Encoder in Dataset example has incorrect type
## What changes were proposed in this pull request?
We propose to fix the Encoder type in the Dataset example
## How was this patch tested?
The PR will be tested with the current unit test cases
Author: CodingCat <zhunansjtu@gmail.com>
Closes #14901 from CodingCat/SPARK-17347.
Diffstat (limited to 'examples')
| -rw-r--r-- | examples/src/main/scala/org/apache/spark/examples/sql/SparkSQLExample.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/examples/src/main/scala/org/apache/spark/examples/sql/SparkSQLExample.scala b/examples/src/main/scala/org/apache/spark/examples/sql/SparkSQLExample.scala index 5cd437d017..129b81d5fb 100644 --- a/examples/src/main/scala/org/apache/spark/examples/sql/SparkSQLExample.scala +++ b/examples/src/main/scala/org/apache/spark/examples/sql/SparkSQLExample.scala @@ -203,7 +203,7 @@ object SparkSQLExample { // No pre-defined encoders for Dataset[Map[K,V]], define explicitly implicit val mapEncoder = org.apache.spark.sql.Encoders.kryo[Map[String, Any]] // Primitive types and case classes can be also defined as - implicit val stringIntMapEncoder: Encoder[Map[String, Int]] = ExpressionEncoder() + // implicit val stringIntMapEncoder: Encoder[Map[String, Any]] = ExpressionEncoder() // row.getValuesMap[T] retrieves multiple columns at once into a Map[String, T] teenagersDF.map(teenager => teenager.getValuesMap[Any](List("name", "age"))).collect() |