diff options
author | zhichao.li <zhichao.li@intel.com> | 2015-07-31 21:18:01 -0700 |
---|---|---|
committer | Reynold Xin <rxin@databricks.com> | 2015-07-31 21:18:01 -0700 |
commit | 6996bd2e81bf6597dcda499d9a9a80927a43e30f (patch) | |
tree | 765e38451f122e762c1e7a8e497f77ab34671131 /python | |
parent | 03377d2522776267a07b7d6ae9bddf79a4e0f516 (diff) | |
download | spark-6996bd2e81bf6597dcda499d9a9a80927a43e30f.tar.gz spark-6996bd2e81bf6597dcda499d9a9a80927a43e30f.tar.bz2 spark-6996bd2e81bf6597dcda499d9a9a80927a43e30f.zip |
[SPARK-8264][SQL]add substring_index function
This PR is based on #7533 , thanks to zhichao-li
Closes #7533
Author: zhichao.li <zhichao.li@intel.com>
Author: Davies Liu <davies@databricks.com>
Closes #7843 from davies/str_index and squashes the following commits:
391347b [Davies Liu] add python api
3ce7802 [Davies Liu] fix substringIndex
f2d29a1 [Davies Liu] Merge branch 'master' of github.com:apache/spark into str_index
515519b [zhichao.li] add foldable and remove null checking
9546991 [zhichao.li] scala style
67c253a [zhichao.li] hide some apis and clean code
b19b013 [zhichao.li] add codegen and clean code
ac863e9 [zhichao.li] reduce the calling of numChars
12e108f [zhichao.li] refine unittest
d92951b [zhichao.li] add lastIndexOf
52d7b03 [zhichao.li] add substring_index function
Diffstat (limited to 'python')
-rw-r--r-- | python/pyspark/sql/functions.py | 19 |
1 files changed, 19 insertions, 0 deletions
diff --git a/python/pyspark/sql/functions.py b/python/pyspark/sql/functions.py index bb9926ce8c..89a2a5ceaa 100644 --- a/python/pyspark/sql/functions.py +++ b/python/pyspark/sql/functions.py @@ -921,6 +921,25 @@ def trunc(date, format): @since(1.5) +@ignore_unicode_prefix +def substring_index(str, delim, count): + """ + Returns the substring from string str before count occurrences of the delimiter delim. + If count is positive, everything the left of the final delimiter (counting from left) is + returned. If count is negative, every to the right of the final delimiter (counting from the + right) is returned. substring_index performs a case-sensitive match when searching for delim. + + >>> df = sqlContext.createDataFrame([('a.b.c.d',)], ['s']) + >>> df.select(substring_index(df.s, '.', 2).alias('s')).collect() + [Row(s=u'a.b')] + >>> df.select(substring_index(df.s, '.', -3).alias('s')).collect() + [Row(s=u'b.c.d')] + """ + sc = SparkContext._active_spark_context + return Column(sc._jvm.functions.substring_index(_to_java_column(str), delim, count)) + + +@since(1.5) def size(col): """ Collection function: returns the length of the array or map stored in the column. |