2
我正在尝试使用Java中的列表来过滤Spark DataFrame。如何在Spark Java中使用isin中的DataFrame过滤器?
java.util.List<Long> selected = ....;
DataFrame result = df.filter(df.col("something").isin(????));
问题是isin(...)方法接受Scala Seq或Scala varang。
传入JavaConversions.asScalaBuffer(选中)也不起作用。
任何想法?
因为我得到的ISIN输入(选择列表)编程,我不能用拳头选项。 第二个选项只适用于Scala代码。 –
Boris
@Boris:更新了我的答案。 – Shankar
@Shankar:很好的答案。努力的荣誉! –