本文介绍了如何在Java中使用Column.isin？的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！
问题描述
我正在尝试使用Java中的列表过滤Spark DataFrame。
I'm trying to filter a Spark DataFrame using a list in Java.
java.util.List<Long> selected = ....;
DataFrame result = df.filter(df.col("something").isin(????));
问题是 isin（...）方法接受Scala Seq 或varargs。
The problem is that isin(...) method accepts Scala Seq or varargs.
传入 JavaConversions.asScalaBuffer（已选中） ）也不起作用。
任何想法？
推荐答案
使用 stream 方法如下：
df.filter(col("something").isin(selected.stream().toArray(String[]::new))))
这篇关于如何在Java中使用Column.isin？的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！