首页 > 数据库技术 > 详细

spark sql 判断一列是否包含某字符

时间:2020-10-26 12:28:50      阅读:339      评论:0      收藏:0      [点我收藏+]

spark sql 的function中有一个 instr 可以判断其中一列是否是另外一列的子字符

新增字段 判断一个字段是否包含另一个字段的字符串,如果包含值为1否则是0

Df.withColumn("newColumn",when(instr(col("aColumn"),col("bColumn"))===0,0).otherwise(1))

如果是判断一列是否包含一个字符串,可以先用lit方法将字符串变成Column,然后再进行判断。

Df.withColums("bColumn",lit("bstr"))
.withColumn("newColumn",when(instr(col("aColumn"),col("bColumn"))===0,0).otherwise(1))

spark sql 判断一列是否包含某字符

原文:https://www.cnblogs.com/Jaryer/p/13877055.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!