《scala》专题

null

我正在尝试使用sbt包构建spark流应用程序，我无法发现这个错误的原因是什么。 这是个错误 这是密码

我刚刚在Eclipse（Oxygen 4.7.3a，Ubuntu 18.04上）中用Scala-IDE插件(4.7.0.v-2_12-201709291352-71A28D0)和一个简单的HelloWorld对象建立了一个Scala项目。如果我将“properties->Scala compiler”设置为2.12，那么一切都将按照预期工作：项目将编译并运行。但是如果我选择任何其他版本（例如，“最

我正在尝试使用Java JTDS驱动程序连接到Scala中的数据库。然而，每当我尝试使用它时，我会得到一个错误，即（Java的？）是错的。 java.lang.unsupportedClassVersionError：net/sourceforge/jtds/jdbcx/jtdsDataSource：Unsupported major.minor版本51.0 null java版本“1.6.0_3

嘿，希望有人能帮我一下。 我正在尝试使用Scala Actors和 Netty.io 库来获取异步http请求。（是的，我知道Scala演员正在被弃用，但这对我来说是一个学习练习） 我编写了一个角色，它接受案例类Request Page（uri： URI）形式的消息。 当它接收到消息时，它创建了必要的Netty对象，需要发出超文本传输协议请求，我已经基于来自[]（http://static.net

如果Scala方法声明太长，无法放在一行中，我会将其分隔成几行，我的重新格式化期望是： 但是在重新格式化代码(< code>control alt L)之后，输出是: 在intellij idea for scala lang中，什么是合适的代码风格规则，我应该设置它来覆盖默认行为并获得我想要的输出风格？ 编辑 当多行会导致： 参数和方法体将具有相同的缩进（2个空格），而不是所需的缩进：具有两个缩

我试图在Scala中反转包含unicode字符的字符串。我想找到最快的方法。到目前为止，我有以下代码： 在我的macbook 2013上，我得到了以下结果： 但我觉得这些数字是假的。我该如何使用scala、sbt和JMH库对函数进行适当的基准测试？ 注意：正如评论中指出的，Java中的微基准测试是一项严肃的业务。请参阅（我如何在Java中编写正确的微基准测试？）和https://groups.go

我做了一些基准测试，结果我不知道如何解释。 我有两个类对泛型数组做同样（计算量很大）的事情，它们都使用专门化（，稍后是）。一个类的定义如下： 第二：（单例） 在第二种情况下，我得到了巨大的性能打击。为什么会这样？（注意：目前我对Java字节码和Scala编译器的内部结构不是很了解。） 以下是完整代码：https://github.com/magicgoose/trashbox/tree/maste

我有两个填充数组[Int]的实现，如下所述。第一个以84毫秒的速度执行，第二个以100倍的速度执行： 为什么第二个变种需要100倍以上的时间？它不是GC，因为我可以删除第一次执行，同时删除第二次执行。我使用Scala 3在Java 11上运行它： 更重要的是，如果你打开implementation，您将通过while。。。 PS：我在Scala 2.12上重复这个测试： 所以Scala 3的问题.

我需要从使用vararg参数的Java接口重写Java方法： 当我尝试在Scala中实现该方法时，如下所示 我在运行时得到一个"java.lang.AbstractMEDError： null"错误。 这是我已经尝试过的： > 使用Scala注释，它应该生成一个Java友好的委托方法= def apply（args:Array[Object]）：Unit=apply（args:*） 它实际上被成功

在试验并发执行时，我想知道如何实际测试它。执行流程具有副作用性质，创建未来是为了包装独立的执行/处理。 我一直在寻找一些关于如何正确单元测试的好例子，下面的场景（和是我希望测试的方法）： 情景#1 情景动机 立即返回，但调用两个执行单独任务的未来（例如，保存分析并将记录存储到数据库）。这些服务调用可以被模拟，但我试图测试的是，一旦我将它们包装在s中，这两个服务都会被调用 场景#2 情景动机 从可以

我在intellij中创建了一个gradle/scala项目。这是我的项目结构 这些是我build.gradle文件的内容 主要课程内容 当我试图构建jar并执行它时，会出现一个错误。这里可能出了什么错？

我试图在Spark中创建成批的行。为了保持发送到服务的记录数量，我想对项目进行批处理，这样我就可以保持数据发送的速率。对于， 对于给定的我想创建 例如，如果输入有100条记录，那么输出应该像一样，其中每个应该是记录（Person）的列表。 我试过了，但没用。 我想在Hadoop集群上运行此作业。有人能帮我吗？

我对Spark和Scala比较陌生。我有一个数据帧，它有以下格式： 我需要做的是获取对应于最新时间戳的行。在上面的示例中，键是Col1、Col2和Col3。Col_TS表示时间戳，Col_7是一个布尔值，用于确定记录的有效性。我想做的是找到一种方法，根据密钥对这些记录进行分组，并保留具有最新时间戳的记录。 因此，上述数据框中的操作输出应为： 我想出了一个部分解决方案，但是这样我只能返回记录分组的列