回答情况：
提问时间：
问题标签：
我有一个包含表单索引的RDD：(:rdd xctx)
[[["1" "32" "44" "55" "14"] 0] [["21" "23" "24" "25" "24"] 1] [["41" "53" "54" "5" "24"] 2] [["11" "35" "34" "15" "64
浏览 2提问于2015-08-03得票数 0
回答已采纳
0] ["b" 1] ["c" 2])
我遇到了一个错误，因为f/map被使用，因为(f/map rdd fn)想在apache中使用zipWithUniqueId()，但是我不知道如何实现它，并且在flambo
浏览 0提问于2015-08-03得票数 1
回答已采纳
我有一个clojure函数，它使用flambov0.60函数api对示例数据集进行一些分析。我注意到，当我使用(get rdd 2)而不是在rdd集合中获取第二个元素时，它将获得rdd集合的第一个元素的第二个字符。我的假设是clojure将rdd集合的每一行视为一个整体字符串，而不是一个向量，以使我能够获得集合中的第二个元素。我正在考虑使用map-value函数将映射的值转换为一个向量，然后我可以获得第二个元素，我尝试了以下方法： (assoc xctx :rdd (-> (:rdd xctx
浏览 2修改于2015-07-29得票数 1
回答已采纳
我读取了一个拼图文件，并使用Flambo api以RDD格式获取数据。我们应用列名称的zipmap并创建一个hash map/ Clojure map 假设我的地图具有以下值 [{:a 1 :b2}
(:require [flambo.api
浏览 4修改于2018-12-26得票数 0
val y = x.repartitionAndSortWithinPartitions(new RFMCPartitioner(1))我想使用clojure的DSL来实现同样的东西，名为flambo
浏览 1提问于2016-07-05得票数 0
回答已采纳
我正在使用与Spark一起工作。我想检索一个包含给定列名的。我编写了一个简单的函数如下： ([data-path column-names and-another] cols (map #(.col data %) column-names)]我在执行它时会得到以下异常。
IllegalArgumentException未找到匹配方法:为类o
浏览 3修改于2016-03-16得票数 1
回答已采纳
spark-streaming "0.1.0-SNAPSHOT"
[yieldbot/flambo[clj-time "0.8.0"]] ;other stuff omitted|- checkouts|- src
|- projec
浏览 3修改于2015-07-19得票数 3
回答已采纳
我有一个使用flambo星火api函数在clojure中开发的函数。(:require [flambo.api :as f] "input
浏览 0修改于2015-07-28得票数 2
回答已采纳
(:require [flambo.api :as f])
[ rdd input ]得到了这个：问题是如何使用flambo
浏览 6修改于2015-08-25得票数 1
回答已采纳
示例使用Scala编写，如下所示：
(:import [org.apache.spark.sql Encoders SparkSession
浏览 0修改于2018-12-24得票数 4
1回答
有一个Flambo ，但是它是一个令人满意的解决方案吗？
我的课程和工作都在斯卡拉。我应该打败Scala，进入Scala世界吗?还是您认为我应该只关注Clojure？
浏览 2提问于2015-04-09得票数 5
回答已采纳
2回答
我创造了一个火花的环境通过使用- (:require [flambo.conf : conf]
[flambo.api :as f]))ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745)，由: java.lang.ClassNotFoundException: flambo.kryo.BaseFlamboRegistrator
浏览 7修改于2018-04-19得票数 1
回答已采纳
下面是代码(clojure / flambo)：(-> (.textFile sc path 8192)
(f/map (f/fn [msg] (json/parse-string
浏览 2提问于2015-09-17得票数 2
回答已采纳
我使用的是Flambo Clojure 0.4.0库(但我不认为这是造成这种情况的原因)和Spark 2.10。 (:require [flambo.conf :as conf])
(def sc (f/spark-context
浏览 0修改于2014-12-11得票数 13
我有一个函数是与偏好脱节的，我想用flambo函数在clojure中实现该解决方案，因此：
将:val作为输入，使用filter
浏览 1提问于2015-09-09得票数 2
1回答
请原谅我的伪代码，我使用的是Flambo Clojure包装器，我不想用Java重写它仅仅是为了问这个问题！
编辑：每个Iterable (即域列表)可能太大，无法在内存中使用。
浏览 0修改于2015-01-08得票数 5
我有一个非常简单的星火程序(在Clojure中使用Flambo，但是应该很容易理解)。这些都是JVM上的对象。我正在一个local实例上进行测试(尽管我猜想火花仍然是序列化和反序列化的)。
浏览 4修改于2015-01-27得票数 5
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号