我在scala中有一个如下所示的地图。Map("x"-> "abc", "y"->"adc","z"->"abc", "l"-> "ert","h"->"dfg", "p"-> "adc")Map("abc"
浏览 4提问于2017-01-20得票数 2
回答已采纳
1回答
我有这个类(在Java中)，我想在星火(1.6)中使用它： private Map<String, Integer> counts;
...}我想将它与这样的星体聚合一起使用(
浏览 3提问于2016-07-06得票数 1
回答已采纳
我有一个Kafka Streams拓扑，其中我加入了5个表，每个表都是在一个主题上创建的，这个主题由一些Kafka连接器生成KeyValue事件，其中键是针对相同的Avro模式产生的，但在我的拓扑中，当我连接这些表时= null }
.map { key, aggregate -> toKeyValue(key, saleProductMapper.aSaleProduct(aggregate</
浏览 7提问于2019-11-28得票数 1
回答已采纳
我试图在RDD上获得以下reduceByKey函数的值，但是它并没有给出正确的结果。scala> val test =sc.parallelize(( (1 to 5).map(x=>("key",x)))).reduceByKey(_-_).collect然后我试着做下面的计算
scala> List (1,2,3,4,
浏览 0提问于2019-01-07得票数 0
回答已采纳
1回答
我已经生成了如下类型的地图1 -> List(1.02),我很难理解如何访问映射中的List()，并使用reduce对元素进行求和。myMap.reduce(???)
浏览 0提问于2018-08-12得票数 0
回答已采纳
3回答
如何在Scala中使用reduce函数？有没有这样的内置函数？我已经在scala中实现了一个查找字数的程序。"orange", "apple", "mango", "orange") val Map= word.ma
浏览 0提问于2014-06-14得票数 1
回答已采纳
4回答
将像AAA:111;BBB:222;333;444;CCC:555这样的字符串简化为Swift中的字典的简单方法是什么？我有以下代码：var astr = str.componentsSeparatedByString(";").map"555"]]["A": "111", "BBB"
浏览 1提问于2015-09-30得票数 1
回答已采纳
在我开始使用Scoobi或Scrunch之前，我想我应该尝试使用Hadoop (0.20.1)的java绑定将WordCount移植到scala (2.9.1)。, recieved org.apache.hadoop.io.LongWritable
在查看了一下之后，我发现这是因为我没有定义正确的map方法(应该是由于缺少override而导致的)，所以我将其修复为所以我看了看我的reducer，注意到reduce签名和我的映射器有相同的</
浏览 0提问于2012-03-25得票数 7
回答已采纳
, Boolean)] = List((0, false), (0, true), (1, true), (1, true))List((0, false), (1, true))
其中的“我可以通过迭代来实现这一点，但是Scala和函数编程一般应该能够使用一组函数来执行这种转换。
浏览 3提问于2017-05-25得票数 2
回答已采纳
我是新的角度，我想要合并项目，有相同的名字从一个数组。cars', quantity: 5},{name: 'trucks',quantity: 2}, {name: 'trucks', quantity: 3}];
所以我想把上面的对象合并到一个名称相等的对象中，这两个对象的数量将被计算在内。
浏览 4提问于2016-12-05得票数 1
回答已采纳
5回答
我正在编写一些扩展来模仿Lisp中的map和reduce函数。R previous);{
var aggregate</
浏览 1提问于2008-09-02得票数 28
回答已采纳
3回答
我正在尝试使用map和reduce函数来计算两个向量之间的向量乘积。, 2)
v2: Array[Int] = Array(3, 5, 1, 5)scalareduce方法(计算每个元组的乘积)。我想的是：
val vecToSum = vecZip.map
浏览 1提问于2016-12-15得票数 2
4回答
对象数组的聚合和转换
、、、、
使用javascript函数式编程方法(如map/reduce)，如何聚合/计数arr1的arr1字段并将其转换为arr2中的键/值对象数组。'task':'do something 3', 'status':'pending'} ,
{'task':'do something 4', 'status':'
浏览 10提问于2016-02-03得票数 1
回答已采纳
我正在尝试用PHPillow做一个(MapReduce的) reduce函数，目前还没有文档，但我真的需要这样做。有谁有在PHPillow中实现Reduce函数的示例吗？<--那是PHPillow* A reduce</e
浏览 0提问于2011-05-27得票数 8
回答已采纳
我正试图在scala中找到相当于assoc-in (clojure)的内容。(",")).map{key=> (key,entry(key))}.toMap,
"subLevelCols" -> Map(entry("cashflowseqnum").asInstanceOf[String].toInt -> (xmlSubLevelAttributesStr.split(&q
浏览 0提问于2018-11-29得票数 0
1回答
国际航空公司
、、
我有一套带有下列结构箱的飞机:物品、时间戳、数量、价格、折扣SELECT item, sum(qty), sum(price), sum(discount) local item = rec.item a.discount = a.discount + b.discount
浏览 3提问于2015-02-05得票数 1
我想将我的updateStateByKey函数替换为mapWithState函数(Spark1.6)，以提高程序的性能。$1(HbaseCoverageStream_mapwithstate.scala:84)def trackStateFunc(key:String, value:Option[Array(BDV(_)).reduce(_ + _).toArray).toOption //throws match error
浏览 4提问于2016-03-12得票数 1
回答已采纳
从某种不同的格式，我可以得到以下的格式。但是现在我想按照下面的输出来更改这个格式。基本上，我想把两个id相同的对象组合起来。
浏览 1提问于2019-10-09得票数 0
回答已采纳
我知道如何使用list monad仅使用“绑定”操作来执行与Scheme的(或Python的) map和filter函数等效的操作。下面是一些Scala示例：scala> List(1,2,3,4,5,6).flatMap {x => List(x * x)}组合在一起的reduce函数。reduce</e
浏览 0提问于2012-06-09得票数 4
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
