Spark SQL - IN句

Question

DataFrameに複数の値を持つ列の条件を追加したいとします。

たとえば、単一の値を扱うことができます。

df.where($"type".==="type1" && $"status"==="completed"). 

以下のように同じ列に複数の値を追加するにはどうすればよいですか。

df.where($"type" IN ("type1","type2") && $"status" IN ("completed","inprogress") 

Answer 1

あなたが探している方法はisinです：通常

import sqlContext.implicits._ 
df.where($"type".isin("type1","type2") and $"status".isin("completed","inprogress")) 

、あなたはどのようにこの

val types = Seq("type1","type2") 
val statuses = Seq("completed","inprogress") 

df.where($"type".isin(types:_*) and $"status".isin(statuses:_*))