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 /sql/core/src/test/java | |
| 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 'sql/core/src/test/java')
| -rw-r--r-- | sql/core/src/test/java/test/org/apache/spark/sql/sources/JavaDatasetAggregatorSuite.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/sql/core/src/test/java/test/org/apache/spark/sql/sources/JavaDatasetAggregatorSuite.java b/sql/core/src/test/java/test/org/apache/spark/sql/sources/JavaDatasetAggregatorSuite.java index 0e49f871de..f9842e130b 100644 --- a/sql/core/src/test/java/test/org/apache/spark/sql/sources/JavaDatasetAggregatorSuite.java +++ b/sql/core/src/test/java/test/org/apache/spark/sql/sources/JavaDatasetAggregatorSuite.java @@ -30,7 +30,7 @@ import org.apache.spark.sql.Encoder; import org.apache.spark.sql.Encoders; import org.apache.spark.sql.KeyValueGroupedDataset; import org.apache.spark.sql.expressions.Aggregator; -import org.apache.spark.sql.expressions.java.typed; +import org.apache.spark.sql.expressions.javalang.typed; /** * Suite for testing the aggregate functionality of Datasets in Java. |