Scala是一种通用编程语言，主要针对Java虚拟机。旨在以简洁，优雅和类型安全的方式表达通用编程模式，它融合了命令式和函数式编程风格。其主要特点是：具有类型推断的高级静态类型系统;功能类型;模式匹配;隐含参数和转换;运算符重载;与Java的完全互操作性;并发
我有时间戳的输入，基于某些条件我需要使用scala编程减1秒或减3个月输入：val date：String =“2017-10-31T23：59：59.000”输出：减1秒... 。
有什么区别：class Person（name：String，age：Int）{def say =“我的名字是”+ name +“，age”+ age}和class Person（val name：String，val age：Int）{ def say =“我的名字是......
我试图在Eclipse Galileo 3.5中安装Scala，但是我收到以下错误：错误消息：无法完成安装，因为找不到一个或多个必需的项目。软件......
list [equals]的表达式类型不符合预期类型seq [[string，int]]
def convert（list：List [String]）：Seq [Either [String，Int]] = list match {case head :: Nil => Right（head.toInt）:: Nil; case head :: tail => Right（head.toInt）:: convert（tail）:: Nil; ...
我有两个RDD：scala> mgrMap.take（5）.foreach（println）（1，Cliff）（2，Raj）（3，Alim）（4，Jose）（5，Jeff）和salMap.take（5） .foreach（println）（1,100）（2,200）（3,300）（4,400）（5,500）我加入了他们......
为spark scala中的数据框中的每个组采样不同数量的随机行
目标是为每个组在数据帧中采样（不替换）不同数量的行。要为特定组采样的行数在另一个数据帧中。示例：idDF是......
为什么Scala解析器组合器不会在重复（rep）子句中传播失败？
如果我有这样简单的解析器defs：def term：Parser [String] =“”“[a-zA-Z”'] +“”“。r ^^ {_.toString} def intWhole：Parser [String] = wholeNumber ^^ {w => w} def simpleTerm：Parser [...
假设我有2个案例类：案例类Money（金额：Int，货币：字符串）案例类人类（名称：String，money：Money）有一种很好的方法可以将字符串列表“翻译”为类Human吗？ ...
在spark中设置textinputformat.record.delimiter
在Spark中，可以设置一些hadoop配置设置，例如， System.setProperty（“spark.hadoop.dfs.replication”，“1”）这个工作，复制因子设置为1.假设...
我有自己的Actor使用配置记录器订阅Akka日志= [“path.MyActor”] MyActor接收日志事件，但我想在运行时停止接收它们。有办法......
我是Cassandra的新手，我正在尝试在卡桑德拉建模。我的查询看起来像下面的查询＃1：从TableA中选择*其中Id =“123”查询＃2：从TableA中选择*其中name =“test”...
如何验证Future [List [T]]中的单个元素以返回Future [List [T]]或抛出异常
这里不需要关注函数的用途，它只用于演示：def readAllByPersonOrFail（person：Person，otherPersonId：Long）：Future [List [Person]] = {val ...
请求帮助以理解此消息.. INFO spark.MapOutputTrackerMaster：shuffle 2的输出状态大小是** 2202921 **字节2202921在这里是什么意思？我的工作是洗牌操作......
为什么Scala案例类复制方法仅使用case类中定义的变量进行参数化？
为什么Scala案例类复制方法仅使用case类中定义的变量进行参数化？基于问答的问题：案例类副本不保持继承特征的状态......
我正在写一个火花工作，以获得按学生日期过滤的最新学生记录。但是当我用十万条记录尝试这个时，它工作得很好。但当我用大量的...运行它时
我遇到了问题，我们正在使用Kafka和spark。我们正在使用forEachRDD：messages.foreachRDD {rdd => val newRDD = rdd.map {message => ...
数据帧scala.reflect.api.JavaUniverse.runtimeMirror（Ljava / lang / ClassLoader;）错误
当我运行一个正常的wordcount程序（使用下面的代码）而不包含任何Dataframe时，我可以使用spark-submit运行应用程序。 object wordCount {def main（args：Array [String]）：Unit = {...
如何从Scala中的Futures返回不同的结果，而不会在嵌套的if语句中结束
我实际上在寻找一个更好的Scala构造，当它在不同条件下返回Future的不同结果时。可以说，在未来之内，我需要先做一些验证......
我的Play Scala（2.5x，2.11.11）应用程序中的代码到目前为止运行得很好（它基于以下链接：https：//fizzylogic.nl/2016/11/27/authorize-访问到您的播放-...