为何Spark中seq.map(col)可直接传入col函数而无需传参?
问题解答
你的理解是对的:map是TraversableLike特质定义的高阶函数,Seq类继承并实现了该特质,所以Seq[String]可以直接调用map方法。
至于为什么直接传col函数就能正常运行,核心原因是Scala支持函数作为一等公民传递,且col的函数类型正好匹配map的要求:
- 先看
map的要求:对于Seq[String]来说,它的map方法需要接收一个类型为String => Column的函数——也就是一个能把字符串转换成Column的函数。 - 再看
col的函数签名:def col(colName: String): Column,这本质上就是一个String => Column类型的函数(接收String参数,返回Column实例)。 - 当你把
col作为参数传给map时,map会自动遍历Seq中的每个元素("A"、"B"),依次将每个元素作为参数传入col函数,相当于自动帮你完成了seq.map(s => col(s))的逻辑,只是写法更简洁。
简单说,map会帮你把Seq里的每个元素“喂”给col函数,你不需要手动传参,只要确保col的参数类型和Seq的元素类型匹配就行。
内容的提问来源于stack exchange,提问作者Carol
相关产品推荐
相关产品推荐

