如何在 Java 中使用 Column.isin? [英] How to use Column.isin in Java?

问题描述

我正在尝试使用 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?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！