如何在Spark Java中使用isin中的DataFrame过滤器？

Question

我正在尝试使用Java中的列表来过滤Spark DataFrame。

java.util.List<Long> selected = ....; 
DataFrame result = df.filter(df.col("something").isin(????)); 

问题是isin（...）方法接受Scala Seq或Scala varang。

传入JavaConversions.asScalaBuffer（选中）也不起作用。

任何想法？

Answer 1

你可以使用这样的东西。

df.filter(col("something").isin("valu1","value2") 

OR

val list = List("value1","value2") 
df.filter(col("something").isin(list: _*) 

在Java：

df.filter(col("something").isin(list.stream().toArray(String[]::new))))