flambo

0熱

1答えて

clojure/flamboを使用したスパークでのセカンダリソート

私は完全に動作するセカンダリソートを実装したスケーラプログラムを持っています。私はそのプログラムを書かれている方法は次のとおりです。 object rfmc { // Custom Key and partitioner case class RFMCKey(cId: String, R: Double, F: Double, M: Double, C: Double)

scala apache-spark clojure secondary-sort flambo 2016-07-05

---

2熱

1答えて

ClojureでSpark Structured Streamingの例を書き込むときのエラー

ClojureでSpark Structured Streamingの例を書き直そうとしています。次のように 例はScalaで書かれている： https://spark.apache.org/docs/latest/structured-streaming-programming-guide.html (ns flambo-example.streaming-example (:impo

scala apache-spark clojure streaming flambo 2017-10-10

---