diff options
| author | Subhobrata Dey <sbcd90@gmail.com> | 2016-05-10 12:32:56 -0700 |
|---|---|---|
| committer | Shixiong Zhu <shixiong@databricks.com> | 2016-05-10 12:32:56 -0700 |
| commit | 89f73f674126bbc1cc101f0f5731b5750f1c90c8 (patch) | |
| tree | e9bdd84d6bf0fba02ff1d2fb3a4e940fa514ed6a /external | |
| parent | 93353b0113158c87e09f0bad91a663a92e9cf1bc (diff) | |
| download | spark-89f73f674126bbc1cc101f0f5731b5750f1c90c8.tar.gz spark-89f73f674126bbc1cc101f0f5731b5750f1c90c8.tar.bz2 spark-89f73f674126bbc1cc101f0f5731b5750f1c90c8.zip | |
[SPARK-14642][SQL] import org.apache.spark.sql.expressions._ breaks udf under functions
## What changes were proposed in this pull request?
PR fixes the import issue which breaks udf functions.
The following code snippet throws an error
```
scala> import org.apache.spark.sql.functions._
import org.apache.spark.sql.functions._
scala> import org.apache.spark.sql.expressions._
import org.apache.spark.sql.expressions._
scala> udf((v: String) => v.stripSuffix("-abc"))
<console>:30: error: No TypeTag available for String
udf((v: String) => v.stripSuffix("-abc"))
```
This PR resolves the issue.
## How was this patch tested?
patch tested with unit tests.
(If this patch involves UI changes, please attach a screenshot; otherwise, remove this)
Author: Subhobrata Dey <sbcd90@gmail.com>
Closes #12458 from sbcd90/udfFuncBreak.
Diffstat (limited to 'external')
| -rw-r--r-- | external/java8-tests/src/test/java/org/apache/spark/sql/Java8DatasetAggregatorSuite.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/external/java8-tests/src/test/java/org/apache/spark/sql/Java8DatasetAggregatorSuite.java b/external/java8-tests/src/test/java/org/apache/spark/sql/Java8DatasetAggregatorSuite.java index 23abfa3970..1a2aea67d9 100644 --- a/external/java8-tests/src/test/java/org/apache/spark/sql/Java8DatasetAggregatorSuite.java +++ b/external/java8-tests/src/test/java/org/apache/spark/sql/Java8DatasetAggregatorSuite.java @@ -25,7 +25,7 @@ import scala.Tuple2; import org.apache.spark.sql.Dataset; import org.apache.spark.sql.KeyValueGroupedDataset; -import org.apache.spark.sql.expressions.java.typed; +import org.apache.spark.sql.expressions.javalang.typed; /** * Suite that replicates tests in JavaDatasetAggregatorSuite using lambda syntax. |