-
- Downloads
[SPARK-8241][SQL] string function: concat_ws.
I also changed the semantics of concat w.r.t. null back to the same behavior as Hive. That is to say, concat now returns null if any input is null. Author: Reynold Xin <rxin@databricks.com> Closes #7504 from rxin/concat_ws and squashes the following commits: 83fd950 [Reynold Xin] Fixed type casting. 3ae85f7 [Reynold Xin] Write null better. cdc7be6 [Reynold Xin] Added code generation for pure string mode. a61c4e4 [Reynold Xin] Updated comments. 2d51406 [Reynold Xin] [SPARK-8241][SQL] string function: concat_ws.
Showing
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/FunctionRegistry.scala 9 additions, 2 deletions...apache/spark/sql/catalyst/analysis/FunctionRegistry.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/stringOperations.scala 64 additions, 8 deletions...che/spark/sql/catalyst/expressions/stringOperations.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/types/DataType.scala 1 addition, 1 deletion.../src/main/scala/org/apache/spark/sql/types/DataType.scala
- sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/analysis/HiveTypeCoercionSuite.scala 10 additions, 1 deletion...e/spark/sql/catalyst/analysis/HiveTypeCoercionSuite.scala
- sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/expressions/StringExpressionsSuite.scala 30 additions, 1 deletion...ark/sql/catalyst/expressions/StringExpressionsSuite.scala
- sql/core/src/main/scala/org/apache/spark/sql/functions.scala 24 additions, 0 deletionssql/core/src/main/scala/org/apache/spark/sql/functions.scala
- sql/core/src/test/scala/org/apache/spark/sql/StringFunctionsSuite.scala 15 additions, 4 deletions...est/scala/org/apache/spark/sql/StringFunctionsSuite.scala
- sql/hive/compatibility/src/test/scala/org/apache/spark/sql/hive/execution/HiveCompatibilitySuite.scala 1 addition, 3 deletions...che/spark/sql/hive/execution/HiveCompatibilitySuite.scala
- unsafe/src/main/java/org/apache/spark/unsafe/types/UTF8String.java 52 additions, 6 deletions...c/main/java/org/apache/spark/unsafe/types/UTF8String.java
- unsafe/src/test/java/org/apache/spark/unsafe/types/UTF8StringSuite.java 50 additions, 12 deletions...t/java/org/apache/spark/unsafe/types/UTF8StringSuite.java
Loading
Please register or sign in to comment