flambo

1La chaleur

1Répondre

Convertir de clojure.lang.LazySeq à type org.apache.spark.api.java.JavaRDD

J'ai développé une fonction dans clojure pour remplir une colonne vide à partir de la dernière valeur non vide, je suppose que cela fonctionne, Étant donné (:require [flambo.api :as f]) (defn replic

1La chaleur

1Répondre

Implémentation d'une fonction flambo mapValues dans clojure

J'ai une fonction clojure qui utilise les fonctions de flambo v0.60 api pour faire une analyse sur un échantillon de données. J'ai remarqué que lorsque j'utilise un (get rdd 2) au lieu d'obtenir le se

1La chaleur

1Répondre

Convertir le vecteur clojure en flambo sql row

Je travaille sur le développement d'une fonction pour convertir un vecteur en une ligne sql afin de le convertir en une trame de données et l'enregistrer dans une table en utilisant SQLcontext dans l'

1La chaleur

1Répondre

zipWithUniqueId() dans flambo utilisant clojure

Je veux créer un rdd tel que chaque ligne a un index. J'ai essayé les éléments suivants Étant donné un RDD: ["a" "b" "c"] (defn make-row-index [input] (let [{:keys [col]} input] (swap! @rd

2La chaleur

1Répondre

Erreur lors de l'écriture de l'exemple Spark Structured Streaming dans Clojure

J'essaie de réécrire l'exemple Spark Structured Streaming dans Clojure. L'exemple est écrit en Scala comme suit: https://spark.apache.org/docs/latest/structured-streaming-programming-guide.html (ns fl