1回答
假设下面是Scala中计算总和的简单代码for (xs <- xss; x <- xs) sum +=x
这种方式计算总和有副作用。我应该怎样做才不会有副作用？
浏览 1提问于2017-07-22得票数 1
我想计算基于geog和time的运行总和。
我需要像这样的结果。我需要这个spark-Scala-RDD。我是Scala领域的新手，我可以用SQL轻松实现这一点。我想在spark -Scala -RDD中这样做，就像使用(地图，平面地图)一样。
提前感谢您的帮助。
浏览 3提问于2017-01-11得票数 0
我们如何订阅Scala项目中作为资源存在的文件，以便可以在服务中检测到对该文件的任何实时更改？例如，有一个Scala代码，它计算文本文件中的数字总和，如何在代码中订阅该文件，以便程序可以在文件中添加任何新数字时立即执行操作。
浏览 0提问于2016-03-17得票数 0
2回答
使用两个列表，这些列表的元素乘法和结果列表的总和可以按以下方式计算。(List1 , List2).zipped.foldLeft(0.0) { case (a, (b, c)) => a + b * c }
如何在Scala中以最优且快速的方式为两个迭代器执行此操作？
浏览 4提问于2020-09-07得票数 0
我的rdd包含如下键值对： (key1, 5),(key3, 20), 我想要执行一个映射操作，将每个key与其在整个rdd中的方面比率相关联，如下所示： (key1, 5/35),(key3, 20/35), 我正在努力寻找一种使用标准函数来做到这一点的方法，任何帮助都将不胜感激。
浏览 12提问于2021-04-11得票数 0
回答已采纳
我需要提取列表元素，以便计算传感器读数的平均值。
我试着使用foreachRDD，但它对我不起作用。有人可以发布一个代码片段，伪代码或一些如何做到这一点的指导吗？Java 8代码也会受到欢迎。
浏览 3提问于2017-04-27得票数 0
我试着在spark 2.1和Scala上按人计算几次行程的总和。我试过了：
甚至更简单：
我是scala的新手，来自python，我不明白:-/尝试建议的解决方案：
编辑2编辑3
和joinedrdd示例(我感觉我有点混淆了我的变量名
浏览 7提问于2017-01-31得票数 0
好的，我想这会很容易，尝试练习Scala的集合运算符，我的例子是一个点的列表。Sum { e2.dist当然，我知道如何使用循环来做到这一点，但要尝试学习scala的方法。谢谢
case class Point(x:Int
浏览 2提问于2012-10-31得票数 2
回答已采纳
使用scala学习函数式编程。偶然发现了这个练习。def fib(n: Int): Int go(n, 0, 1)}
如果有人感兴趣，这是来自Chiusano和
浏览 0提问于2015-02-13得票数 2
1回答
我正在筛选一个庞大的数据集，根据相同的键进行解析和分组。但是要使用groupBy函数，我需要将迭代器转换为Array。为什么Iterator中没有groupBy？我知道迭代器是如何工作的，并且迭代器只能遍历元素一次。但是当你在迭代器上提供map、filter、foreach等方法时，为什么不同时提供groupBy呢？
浏览 1提问于2018-10-13得票数 0
5回答
--- 20 | 20 | 20我试图在这个列中添加一个列，这是每一行值的总和| 30 50 | 50 | 50 | 150我已经到了
val newDf: DataFrame = df.select(
浏览 6提问于2016-04-01得票数 9
回答已采纳
scala> val dataArray = Array("a,1|2|3","b,4|5|6","a,7|8|9","b,10|11|12") dataRDD: org.apache.spark.rdd.RDD[Strin
浏览 15提问于2020-05-08得票数 0
回答已采纳
that does not contain the sum of all values of one column 我尝试在dataframe中添加一列，该列包含同一dataframe中一列的所有值的总和现在我想添加一个名为Sum的列，它将包含Rating列的所有值的总和。 我有一个评级数据框 Ratings列名: USerID，MovieID，Rating，UnixTimeStamp。880606923|+------+-------+------+-------------+
浏览 25提问于2019-01-23得票数 0
回答已采纳
3回答
下面是一个计算斐波那契数列的Scala流：因此takeSum(7)将返回'0,1,1,2,3'
假设n值sum将包含fib序列的子集。
浏览 2提问于2016-09-09得票数 0
回答已采纳
我希望使用Spark计算每个事务从最后一个小时开始运行的总和。我有以下三个字段的dataframe，并希望计算第四个字段，如下所示：Cust-1 6/1/3 15Cust-3 6/1/2015 19:24:34 1 1
我想计算例如:20
浏览 3提问于2016-03-19得票数 1
回答已采纳
1回答
记录的过程值
、、、
我正在尝试用scala编写伪代码(就像这些示例一样)。123 History 5 80 ((a,b,c)=>(a, sum(mul(b,c))&#x
浏览 1提问于2020-02-27得票数 1
我想使用Scala在Flink中计算流数据的分位数。我的问题类似于这个，但比这个简单。我认为这可以通过定义一个自定义聚合函数来完成，但我正在寻找一些Scala示例。我计算了总和，平均值，我想计算第95个百分位数。events.map(_.stat1).sum/events.size,}
我希望能够在collect函数中以类似的方式计算第
浏览 1提问于2018-08-03得票数 1
6回答
]] = List(Map("a" -> 1, "b" -> 2.8), Map("a" -> 3, "c" -> 4), Map("c" -> 5, "d" -> "abc"))
我使用下面的代码来计算关键字
浏览 0提问于2012-04-04得票数 2
回答已采纳
5回答
我用Java实现了一个。我想将它与Java中内置的浮点加法和Mathematica中的无限精度加法进行比较。然而，我拥有的数据集并不适合测试，因为这些数字彼此接近。(条件编号~= 1)有人能建议如何生成大量可能导致严重舍入误差的数据吗？
浏览 1提问于2011-07-07得票数 0
回答已采纳
有没有更好的方法来做到这一点：或者这样：我认为这是一个很常见的操作，所以我期待的是一些更时髦的东西，比如：
浏览 1提问于2010-05-21得票数 9
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
