diff options
| author | szheng79 <szheng.code@gmail.com> | 2015-04-22 13:02:55 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2015-04-22 13:02:55 -0700 |
| commit | fbe7106d75c6a1624d10793fba6759703bc5c6e6 (patch) | |
| tree | e96c8022da92dcdc0ffb84a6be8ba191b4dc38a0 /sql | |
| parent | cdf0328684f70ddcd49b23c23c1532aeb9caa44e (diff) | |
| download | spark-fbe7106d75c6a1624d10793fba6759703bc5c6e6.tar.gz spark-fbe7106d75c6a1624d10793fba6759703bc5c6e6.tar.bz2 spark-fbe7106d75c6a1624d10793fba6759703bc5c6e6.zip | |
[SPARK-7039][SQL]JDBCRDD: Add support on type NVARCHAR
Issue:
https://issues.apache.org/jira/browse/SPARK-7039
Add support to column type NVARCHAR in Sql Server
java.sql.Types:
http://docs.oracle.com/javase/7/docs/api/java/sql/Types.html
Author: szheng79 <szheng.code@gmail.com>
Closes #5618 from szheng79/patch-1 and squashes the following commits:
10da99c [szheng79] Update JDBCRDD.scala
eab0bd8 [szheng79] Add support on type NVARCHAR
Diffstat (limited to 'sql')
| -rw-r--r-- | sql/core/src/main/scala/org/apache/spark/sql/jdbc/JDBCRDD.scala | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/jdbc/JDBCRDD.scala b/sql/core/src/main/scala/org/apache/spark/sql/jdbc/JDBCRDD.scala index b9022fcd9e..8b1edec20f 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/jdbc/JDBCRDD.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/jdbc/JDBCRDD.scala @@ -60,6 +60,7 @@ private[sql] object JDBCRDD extends Logging { case java.sql.Types.NCLOB => StringType case java.sql.Types.NULL => null case java.sql.Types.NUMERIC => DecimalType.Unlimited + case java.sql.Types.NVARCHAR => StringType case java.sql.Types.OTHER => null case java.sql.Types.REAL => DoubleType case java.sql.Types.REF => StringType |