私は使用sparklyrしていますが、うまく機能しているようです。ただし、以前のコードの一部は実装されません。
使用時期
complete.cases
私は得る
エラー: org.apache.spark.sql.AnalysisException: 未定義の関数 COMPLETE.CASES
quantile関数に対して同じ結果が得られます
さらに、Spark データフレームでis.naは が同じ方法で計算されないようです。だから私がするとき
filter(!is.na(V1) & is.na(V2))
V1でいっぱいでで空のすべてのフィールドを返すのではなく、空のデータフレームを取得しますV2。
これらの関数を で使用/変更するsparklyr方法、またはこれらのラッパーを構築する方法に関するアドバイスはありますか?