本文介绍了如何在 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(selected) 也不起作用.
有什么想法吗?
推荐答案
使用stream方法如下:
df.filter(col("something").isin(selected.stream().toArray(String[]::new))))
这篇关于如何在 Java 中使用 Column.isin?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！