《scala》专题
-
从Spark RDD中提取数据，并在scala中填充元组
我在Hadoop / Spark框架的顶部使用Scala。 实际上我的数据是这种类型的： 并且，这是此数据记录中前两行的示例： 在实际情况下，每行有194列，我总共有160多万条记录。 有了这个数据集，我想填充一个新的列表，类型为: 其中，第一个“Int”是每行的每个字段（COD_LOCALE_PROGETTO、CUP…），第二个字段是每个字段的大小（19、3、…）；第三个字段是已经编码在变量中的
-
Spark中的Scala.ScalaReflectionException-从命令行提交
-
IncompatibleClassChangeError：用ScalaCheck和ScalaTest实现类
我在这里漏掉了什么？
-
由于StatibloggerBinder.class中的去重错误，Scala SBT程序集无法合并
运行“SBT程序集”时的问题： [错误]合并java.lang.runtimeException时遇到3个错误：删除重复：在以下位置找到不同的文件内容：.vlasakakis/.ivy2/cache/ch.qos.logback/logback-classic/jars/logback-classic-1.1.2.jar:org/slf4j/impl/staticMDCBinder.class/u
-
过滤scala中对象列表的列表属性
我正在尝试过滤scala中对象列表的列表属性。例如： 用java定义的类 我的过滤器函数返回字符串列表而不是结果列表 UPDATE我想取回listOf中的所有结果，其中每个结果的名称属性被过滤。
-
如何最好地通过 Scala 中的 Map[String， Int] 过滤 Seq[对象]？
我试图通过映射[objectid: String，Int]过滤包含对象的Seq[Object],其中Object.id是映射中的一个键。 我想返回一个新的Map，其中只包含id在原始映射中的对象及其Int值。因此函数应该返回Map[Object，Int] 这是我到目前为止的情况？实现这一目标的最佳方法是什么？
-
在scala spark2中运行saveAsNewAPIHadoopDataset到hbase时获取空指针异常
此函数转换Hbase格式的数据 这是我在第125行得到的错误：hbaseputs.saveasnewapiHadoopDataSet（job.getconfiguration）
-
Scala spark thorws ArrayOutOfBound异常计数，显示函数
我在scala spark中运行以下代码，每当我点击count（）或show这样的动作函数时，就会出现数组越界异常。但是我可以打印模式 错误堆栈跟踪
-
为什么scala代码是用Java编译的？
我试图理解Scala代码如何在Java的IDE中与Java一起工作。我在使用Spark Java时遇到了这个疑问，在Spark Java中，我看到Scala包也在代码中，并且使用了相应的类和方法。 我的理解是，Scala代码需要Scala的编译器转换成Java.class文件，然后从它们开始JDK在JVM中完成它的部分，转换成二进制文件并执行操作。如果我说错了，请指正。 之后，在eclipse中的
-
使用scala和maven的可执行jar
我试图用scala和Maven创建可执行jar。我正在使用maven-scala-plugin和maven-assembly-plugin，但在我看来，汇编插件被忽略了。我得到没有依赖项的jar和包含没有主类行的manifest。
-
Scala参与者：返回一个不同于任何类型的未来。
我正在努力读完一本关于Scala Actor的书，我遇到了一点语法问题。在实践中，我倾向于这样分配我的变量和函数定义： 在项目名称后包含项目的（返回）类型。虽然我知道这不是必需的，但我已经习惯了这种约定，并发现它使代码更容易被我自己理解。尽管如此，请观察以下示例： 上面的代码在编译时产生一个错误，抱怨服务器返回了Future[Any]，而不是Future[String]。我理解，通过从sendMs
-
播放scala web套接字-按顺序不并行地点击web套接字
我已经创建了一个web socket来接收单个消息，它将进行一些处理并将响应消息返回给客户端。我已经使用Play框架创建了web socket。下面给出了代码片段。 代码片段: 我已经测试了我的web套接字从http://www.websocket.org/echo.html.我连接了我的web套接字，并按顺序传递了三个消息，分别是“1”、“2”和“3”。我在传递这些消息时得到了下面的响应。 we
-
scala中的基准测试[副本]
可能的重复: 我如何在Java写一个正确的微基准？ 假设我有两个算法，我如何找出哪一个性能更高？ 我的意思是，我可以用数学来证明它，但是如果我使用一些库，这可能会变得单调乏味。没有数学，我从来没有学会过如何做正确的基准。
-
为什么在Scala中独立代码块的执行时间依赖于执行顺序？[副本]
我有一个用Scala写的程序。我想测量不同独立代码块的执行时间。当我以明显的方式（即在每个块之前和之后插入)时，我观察到执行时间取决于块的顺序。前几个块总是比其他块花更多的时间。 我创建了一个再现这种行为的极简示例。所有代码块都是相同的，为了简单起见，为整数数组调用。 运行和的程序后，我的控制台如下所示： HashCodeExperiment耗时14.630283毫秒 HashCodeExperi
-
在控制器外部渲染scala模板？（第二场）
我正试图将发送通知电子邮件与导致它们的事件分离开来。到目前为止，我正在将一个邮件对象（）从控制器传递给Akka actor（），然后它通过play mailer插件的play easymail包装发送邮件。邮件正文由邮件对象在传递给参与者后生成，HTML由Scala模板生成。 此模板包含带有绝对URL的链接，通过调用 但是，在尝试呈现模板时，我遇到了RuntimeException。 堆栈跟踪如下