spark sql 判断一列是否包含某字符
Posted JunCode
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了spark sql 判断一列是否包含某字符相关的知识，希望对你有一定的参考价值。
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 判断一列是否包含某字符的主要内容，如果未能解决你的问题，请参考以下文章