aboutsummaryrefslogtreecommitdiff
path: root/python/pyspark/mllib/tree.py
diff options
context:
space:
mode:
authorwangfei <wangfei1@huawei.com>2015-02-04 15:12:07 -0800
committerMichael Armbrust <michael@databricks.com>2015-02-04 15:12:15 -0800
commit8b803f68ccf4e6c7194a00c22a71dddf206f3f59 (patch)
treec3fa02e03c68f0274574d0340dfeb826760fd3be /python/pyspark/mllib/tree.py
parent38ab92e4906a92a614b15224f0e83132f561f6d7 (diff)
downloadspark-8b803f68ccf4e6c7194a00c22a71dddf206f3f59.tar.gz
spark-8b803f68ccf4e6c7194a00c22a71dddf206f3f59.tar.bz2
spark-8b803f68ccf4e6c7194a00c22a71dddf206f3f59.zip
[SPARK-5367][SQL] Support star expression in udfs
A follow up for #4163: support `select array(key, *) from src` Since array(key, *) will not go into this case ``` case Alias(f UnresolvedFunction(_, args), name) if containsStar(args) => val expandedArgs = args.flatMap { case s: Star => s.expand(child.output, resolver) case o => o :: Nil } ``` here added a case to cover the corner case of array. /cc liancheng Author: wangfei <wangfei1@huawei.com> Author: scwf <wangfei1@huawei.com> Closes #4353 from scwf/udf-star1 and squashes the following commits: 4350d17 [wangfei] minor fix a7cd191 [wangfei] minor fix 0942fb1 [wangfei] follow up: support select array(key, *) from src 6ae00db [wangfei] also fix problem with array da1da09 [scwf] minor fix f87b5f9 [scwf] added test case 587bf7e [wangfei] compile fix eb93c16 [wangfei] fix star resolve issue in udf (cherry picked from commit 417d1118cd720b616bfd30e9c1a0bfb1838e8cbd) Signed-off-by: Michael Armbrust <michael@databricks.com>
Diffstat (limited to 'python/pyspark/mllib/tree.py')
0 files changed, 0 insertions, 0 deletions