Scala是一种通用编程语言，主要针对Java虚拟机。旨在以简洁，优雅和类型安全的方式表达通用编程模式，它融合了命令式和函数式编程风格。其主要特点是：具有类型推断的高级静态类型系统;功能类型;模式匹配;隐含参数和转换;运算符重载;与Java的完全互操作性;并发
我有两个 FoldLeft 的例子，但我无法真正掌握其中的逻辑。 第一个例子： val 甜甜圈: List[String] = List("Plain", "Strawberry", "Glazed") println(甜甜圈.fo...
我想读取 json 中包含点（.）的列。如果没有点，下面的代码可以正常工作。 验证数据 = """{ “abc.id”：[{ “id”：“123”， “n...
我正在使用 Ga特林 作为性能测试工具。我想在用户失败或退出时将会话属性用户名写入 file.txt 中。我正在使用 scala 语言使用加特林。 场景：...
我有一个数据集，例如： 我想按 Col1、Col2、Col3 对数据进行分组，并希望应用隔离林 按结果对该组进行排序。 如果 col3 值只是 sin，我可以应用隔离森林...
如何确定 Apache Spark 和 scala 中的无效 XML 字符串
我有一个用户定义的函数，如下所示 案例类主体结果（文本：字符串，代码：字符串） val bodyudf = udf{ (body: 字符串) => //将 body 标签显式附加到
我必须将已排序的各种集合合并到一个已排序的集合中。此操作需要针对不是很大的集合（大约 5 个元素）并且没有太多的集合来完成...
在 Scala 3 中使用 Lift JSON 将 Java 字符串反序列化为 Java 类
我正在尝试在 JSON 中为简单的 Scala3 类型（例如 case 类）实现“通用”反序列化 - 我需要传入序列化的 JSON 和目标类的名称（字符串）......
我的 CSV 文件有超过 30 列，其中一些列代表 json 字符串，例如 - "{""name"": ""value1"",""name2"": &...
无法使用 Spark dataframe 和 scala 创建 CSV，而是创建文件夹名称中包含“.csv”的文件夹
我无法使用 Spark 数据框编写或创建 csv。相反，它为我创建目录。这是我的代码 com.package.dssupplier 包 导入 org.apache.spark.sql.{SaveMode、SparkSessi...
Spark：java.lang.NoClassDefFoundError：scala/collection/mutable/ArraySeq$ofRef
我正在尝试使用 Spark-Submit 运行一个简单的字数统计程序并收到异常。 线程“main”中的异常 java.lang.BootstrapMethodError: java.lang.NoClassDefFoundError: 斯卡拉/
如何从 Cask 中的 RawDecorator 返回响应对象
我正在尝试使用 Cask HTTP 框架中的 RawDecorator 来验证 devKey，但我不确定我是否理解当 devKey 无效时如何返回错误响应。这是我正在尝试的： CL...
如何使用猫将 `NonEmptyList[Either[Error, User]]` 转换为 `Either[Error, NonEmptyList[User]]`？
我正在使用cats，想知道如何用它来转换数据： val data = NonEmptyList[任一[错误，用户]] 到 val 目标：Either[Error, NonEmptyList[User]] = howToConvert(data)
如何在 Spark Streaming 作业中查找数据帧的大小
我正在尝试查找每个批次中 Spark 流作业中数据帧的大小。我能够成功地找到批处理作业的大小，但是当涉及到流式传输时，我无法做到......
ZIO 不允许通过重试 Schedule.exponential 来测试效果
第一次重复后测试就挂起 test("测试重试指数") { 为了 { _ <- TestClock.adjust(10.milliseconds) res <- ZIO.fail("fail").retry(Schedule.
我正在将 Yarn 集群上的 Flink 作业的部署模式从会话模式更改为应用程序模式。我有很多相同实施的工作，除了其中两个之外，所有工作都运行良好。 在
将 ADT/密封特征层次结构编码到 Spark DataSet 列中
如果我想在 Spark DataSet 列中存储代数数据类型 (ADT)（即 Scala 密封特征层次结构），最佳编码策略是什么？ 例如，如果我有一个 ADT，其中叶子...
我在类文件中保留一个字符串值。我想在另一个 scala 主函数中获取这个字符串。我如何在主 scala 代码中获取字符串 abc。 包集成.utils 对象模式Stru...
我有一个数据框。如果任何列具有空值，我想引发异常。我可以通过对列名称进行硬编码并放置或检查条件来做到这一点。我怎样才能让它充满活力和表现......
我有一个具有数组列的数据框。它包含值列表以及空值。我想用其他值替换空值。 导入spark.implicits._ val 列=数组("我...
我在scala中写了一些性能关键的代码，并且时不时地遇到如下代码： 变量索引 = 开始 - 1 而{索引+= 1;索引 < end} do something Then I want to write a