请给我一些帮助：我需要给这个函数添加一个参数，但是这个语法不正确：
val input_parameter = 100
df_filtered = (df.filter(( (F.col('LOCID') != F.col('LOCID2') ) &
(F.col('distance') <= F.col('RADIUSINMETERS') + F.col('RADIUSINMETERS2') + input_parameter)
))
)非常感谢！
1条答案
按热度按时间eaf3rand1#
spark需要知道您正在传递一个变量，为了做到这一点，我们需要确保我们在内部传递
lit()函数，从文档中创建文字值的列。
更多阅读此处