scala

2热度

2回答

我想提高我的Spark Scala技能，我有这种情况下我找不到操作的方法，所以请指教！我有原始数据如下图所示波纹管是：我要计算的数列的每个结果的百分比。例如。最后一个错误值是64，占所有列值的百分比是多少。请注意，我用的sqlContext读取原始数据Dataframes：这里是我的代码： val df1 = df.groupBy(" Code") .agg(sum("count").al

0热度

1回答

斯卡拉自我不承认案件类内特质

为什么自我符号不被识别在这里？我正在使用Scala 2.12。 trait Parsers[ParseError, Parser[+_]] { def or[A](s1: Parser[A], s2: Parser[A]): Parser[A] case class ParserOps[A](p: Parser[A]) { def |[B>:A](p2: Pars

0热度

1回答

无法导入新生成的游戏框架项目为IntelliJ IDEA的15

当我尝试到新创建的游戏框架项目导入到我的IntelliJ IDEA 15我得到了以下异常： Java HotSpot(TM) 64-Bit Server VM warning: ignoring option MaxPermSize=384M; support was removed in 8.0 [info] Loading settings from plugins.sbt,scaffold

0热度

1回答

DynamoDB/Scanamo：提供的关键元素与模式不匹配

我一直试图通过Scanamo库使用DynamoDB。我的Scala代码如下所示： package my.package import com.amazonaws.ClientConfiguration import com.amazonaws.regions.{Region, Regions} import com.amazonaws.services.dynamodbv2.AmazonD

1热度

1回答

OptionalT fromOptional和liftF在ScalaZ

从来就一直看着单子变压器的一些例子有Cats，我试图重现那些Scalaz 在这里，我有一个为理解我第一次收到一个可选的，我flatMap与OptionalT，第二个函数返回员工的未来。这里我的代码 //Attributes for this example sealed trait Employee { val id: String } final ca

0热度

1回答

星火错误：异常线程“main” java.lang.UnsupportedOperationException

我写一个斯卡拉/火花程序，会发现该雇员的薪水最高。员工数据可以CSV文件形式提供，而薪金列有数千个逗号分隔符，并且还有一个$前缀，例如$ 74,628.00。为了解决这个逗号和美元符号，我已经用Scala编写这将分割每行一个解析器功能“”然后每一列映射到各个变量被分配到一个案例类。我的解析器程序看起来像下面。为了消除逗号和美元符号，我使用替换函数将其替换为空，然后最终将类型转换为Int。 de

0热度

1回答

如何处理XML数据集？

我是火花和编程语言的新手。我需要一些帮助来解析基于每个标签的XML文件。这里是我的小例子输入文件： XML File: <?xml version="1.0"?> <?xml-stylesheet type="text/xsl" href="myfile.xsl" ?> <bookstore specialty="novel"> <book style="autobiograp

2热度

1回答

错误与SBT组装和播放框架

极力打造的一出戏（2.6.6）+ scala.js应用脂肪罐子，让 [错误]（播放/ *：组装）进行重复数据删除：不同的文件内容在下面找到： [error] /home/user/.ivy2/cache/com.typesafe.play/play_2.12/jars/play_2.12-2.6.6.jar:play/reference-overrides。 conf [error] /home/

1热度

1回答

akka stream阅读时无尽http流反压

基本上这里是我使用的代码。当我用curl进行连接时，我发现curl命令中的所有实体都非常快。当我尝试模仿与akka相同的行为时，打印出我得到的元素之间会有很大的停顿。流动波纹管在某种程度上受到了压力，并且在前4条消息之后，1条消息的其余部分会在明显的打印线之后到达。前4条消息大约是2k JSON，最后一条没有。 5是80k JSON。最后一个实体（编号5）也是最大的块，我得到它在流完成之前

0热度

2回答

如何在play framework中使用cacheApi设置清理缓存超时？

在我的播放应用程序中使用cacheApi，我想知道我是否可以有一些超时缓存清理？进出口使用的cacheApi对象的方法if the data is in cache bring from cache, if not, so go get it from the server with an api call ，现在我想每24个小时清理缓存，能够从服务器带来了新的数据。我是如何完成这样的事情的？