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))