flambo

3熱度

1回答

Leiningen結賬時庫名稱中有斜線

我試圖使用Leiningen中的Checkout Dependencies功能來處理使用結帳Flambo的結算項目。我project.clj看起來像： (defproject spark-streaming "0.1.0-SNAPSHOT" :dependencies [[org.clojure/clojure "1.5.1"] [yieldbot/flambo "0.4.0-S

clojure symlink leiningen flambo 2014-11-03

---

2熱度

1回答

在火花DAG中的外部組

根據火花DAG vizualization，在階段0中執行groupBy後，在階段1中執行groupBy。在我的代碼中只有一個groupBy，並且不會期望任何其他轉換我正在做結果groupBy。 下面的代碼（clojure/flambo）： ;; stage 0 (-> (.textFile sc path 8192) (f/map (f/fn [msg] (json/parse-st

clojure apache-spark flambo 2015-09-17

---

2熱度

1回答

在Clojure中寫Spark結構化流示例時出現錯誤

我想重寫Clojure中的Spark結構化流示例。 的例子是用Scala編寫如下： https://spark.apache.org/docs/latest/structured-streaming-programming-guide.html (ns flambo-example.streaming-example (:import [org.apache.spark.sql Enco

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

---

1熱度

1回答

Clojure - 使用Flambo時在DataFrame中找不到匹配的方法

我正在使用Flambo與Spark一起使用。我想要檢索包含給定列名稱的DataFrame。我寫了一個簡單的函數如下： (defn make-dataset ([data-path column-names and-another] (let [data (sql/read-csv sql-context data-path) cols (map #(.col dat

apache-spark clojure apache-spark-sql spark-dataframe flambo 2016-03-16

---