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入力(選択リスト)を取得するので、私は拳オプションを使用することはできません。 2番目のオプションはScalaコードでのみ動作します。 –
Boris
@Boris:私の答えを更新しました。 – Shankar
@Shankar:素敵な答え。努力の名誉! –