《scala》专题

我是新来的Play框架。我试图配置MySQL数据库作为一个数据源，用于播放。 我已经做了以下设置来连接mysql数据库进行播放。。 db。违约driver=com。mysql。jdbc。驾驶员 db.default.url="jdbc：mysql://localhost/phpmyadmin/index.php?db=formdemo 但我得到以下配置错误。 play.api.配置$$anon1美

我正在使用Play框架调用一个web服务。功能是： } 我得到的错误是： 我不明白我做错了什么？有什么想法吗？

我试图创建Kafka直接流与提供偏移外部在我的火花流模块，但它导致以下编译错误。 下面是创建Kafka直接流的代码 下面是我遇到的编译错误。有什么想法/指针吗？

fabric8 kubernetes Java&Scala客户机API非常适合与kubernetes（或OpenShift）进行对话，但它的文档非常稀疏。向kubernetes Pod中运行的容器添加资源需求的代码示例是什么？

我想选择一个特定的元素： 我得到了这个错误： 线程“main”组织中出现异常。阿帕奇。火花sql。AnalysisException：无法解析文件。柱。列[_name]'由于数据类型不匹配：参数2需要整数类型，但“_name”是字符串类型。；在org。阿帕奇。火花sql。催化剂分析套餐$AnalysisErrorAt。组织的故障分析（scala包：42）。阿帕奇。火花sql。催化剂分析检查分析$$

我有以下模式的数据框架。我希望包括嵌套字段在内的所有列都应该按字母顺序排序。我想要scala spark。 当我使用schema.sort（_. name）排序时，我得到以下模式（嵌套数组和结构类型字段没有排序） 我想要的模式如下所示。（即使是metadata1（ArrayType）和metadata2（structType）内的列也应该排序） 提前感谢。

Scala\u Spark\u DataFrameReader\u csv的文档表明，Spark可以记录在读取时检测到的格式错误的行。csv文件 -如何记录格式错误的行 -是否可以获取包含格式错误行的val或var？ 链接文档中的选项是：maxMalformedLogPerPartition（默认值10）：设置Spark将为每个分区记录的最大错误行数。超过此数字的格式错误记录将被忽略

我正在尝试使用spark df读取spark中的CSV文件。文件没有标题列，但我想有标题列。如何做到这一点？我不知道我是否正确，我写了这个命令- 并将列名作为列的_c0和_c1。然后我尝试使用：val df1=df.with列重命名（"_c0"，"系列"）将列名更改为所需的名称，但我得到"with列重命名"不是单元上的成员。 PS：我已经导入了spark.implicits._和spark.sql

假设我有以下几列： 现在我想验证数据是否与列名模式同步。对于，该列中的数据应该仅为。我在引用此链接后尝试了下面的代码，但它在我的代码的最后一行显示错误。 因此，它不接受代码的最后一行。映射{行= 我输入了一条无效记录（第三条），如下所示： 在本例中，我已经为id列输入了一个字符串值（应该是一个数字），因此在检查列架构及其数据后，它应该抛出一个错误，说明记录与列架构不匹配。

SBT将编译后的scala文件放在目标/scala文件夹中- 据我所知，类文件包含JVM字节码。它们与语言无关。 那么，文件夹使用语言名称的原因是什么？我希望Scala和Java的类字段都位于同一个目录中。

我想将包含字符串记录的RDD转换为Spark数据帧，如下所示。 模式行不在同一个中，而是在另一个变量中： 所以现在我的问题是，我如何使用上面两个，在Spark中创建一个数据帧？我使用的是Spark 2.2版。 我确实搜索并看到了一篇帖子：我可以使用spack-csv将表示为字符串的CSV读取到Apache Spark中吗？然而，这并不是我所需要的，我也无法找到一种方法来修改这段代码以在我的情况下工

我实现了一个Scalatra servlet，现在想要创建一个可执行的jar，就像本教程中所描述的那样：http://www.scalatra.org/2.2/guides/deployment/standalone.html 我使用IntelliJ IDEA和Scala插件进行开发，并使用sbt来构建和运行我的servlet（我使用sbt-想法来生成项目文件）。我的问题是，当我尝试编译我的项目时

我希望向sbt添加一个自定义源生成器，并将其与scalapb（Scala协议缓冲区生成器）一起使用。每一个都独立工作。然而，当两者结合在一起时，项目在清理后第一次编译失败。如果我再次运行compile，它就会成功。 错误消息： 要再现此错误，您需要在src/main/protobuf中至少有一个proto文件。 我的自定义任务和scalapb这两个源生成器会发生冲突，这让我感到困惑。它们不应该都写

我想在我的SBT项目中使用ScalaPB插件。但是，当我试图编译该项目时，我得到一个错误，该错误表明“object gen不是包scalapb的成员”。那么，我该如何配置这个插件来处理我的项目呢？ 我按照Github页面上的说明进行操作，但它不起作用。 我的项目具有以下结构，即标准Maven项目结构： 这是文件： 这是文件： 这是构建。sbt文件。这是错误发生的地方。 我希望这个项目在运行时应该编

我需要在PySpark中处理以下场景。 我有以下格式的csv数据，其中分隔符为，名称列中的数据用双引号括起来。标头也由相同的分隔符分隔 我需要清理数据并获得如下数据框 此外，在Scala Spark中，我们如何实现同样的目标？