flambo

1зной

1ответ

Преобразование из clojure.lang.LazySeq для ввода org.apache.spark.api.java.JavaRDD

Я разработал функцию в clojure, чтобы заполнить пустой столбец из последнего непустого значения, я предполагаю, что это работает, учитывая (:require [flambo.api :as f]) (defn replicate-val [ rd

3зной

1ответ

Leiningen checkouts, когда библиотека имеет косую черту в своем имени

Я пытаюсь использовать функцию Checkout Dependencies в Leiningen для работы над проектом, который использует выписку Flambo. Моя project.clj выглядит что-то вроде: (defproject spark-streaming "0.1.0-S

2зной

1ответ

Результатов обновления вектора в Clojure

У меня есть функция в развитыхах в Clojure с помощью flambo искровых функций API (:require [flambo.api :as f] [clojure.string :as s]) (defn get-distinct-column-val "input = {:col val}" [ xc

1зной

1ответ

Реализация функции flambo mapValues в clojure

У меня есть функция clojure, которая использует функции api flambo v0.60 api, чтобы выполнить некоторый анализ набора образцов данных. Я заметил, что когда я использую (get rdd 2) вместо получения вто

2зной

1ответ

Посторонние группиЙ в искре DAG

В соответствии с искрой DAG визуализации есть groupBy выполняются на стадии 1, после groupBy выполняется на стадии 0. У меня есть только один groupBy в моем коде, и не ожидать какие-либо других преобр

1зной

1ответ

Convert clojure vector to flambo sql row

Я работаю над созданием функции для преобразования вектора в строку sql для дальнейшего преобразования его в кадр данных и сохранения его в таблицу с использованием SQLcontext в искры Apache. Я развив

1зной

1ответ

zipWithUniqueId() в flambo using clojure

Я хочу создать rdd, чтобы каждая строка имела индекс. Я пробовал следующий Учитывая РДУ: ["a" "b" "c"] (defn make-row-index [input] (let [{:keys [col]} input] (swap! @rdd assoc :rdd (-> (: