我使用 Spark 框架开发了一个非常简单的 API（参考：sparkjava.com）。我编写了一个删除处理程序，并使用 Postman 对其进行了测试。 问题 当我尝试使用 分配一个值时，即使...

我有一个名为 details 的列，它具有特殊字符，因为我想用 替换它。如何在 spark Java 中做到这一点？|- 我试过： regex_replace(details ,"|","-") ...

我在 postgres db 中有 2 个表，我需要将它们加入并将生成的输出发送到 kafka。为此，我编写了一个使用 spark 框架的 java 代码。我的代码示例如下： 主类： privat...

我正在使用 Spark Java（不是 scala 或 python）。 我有一个数据帧，我想从行访问特定字段。如果它是 String，我已经能够获得字段值，但我不知道如果它是 Long、Int 该...

我正在使用 Spark SQL Java（不是 scala 或 python）。这是我的数据集的简化示例（它的列比这多得多）： 编号 引用 E_id F_id G_id 0 [E_id] 0000 ...

我正在使用 Spark Java（不是 scala、python）。 我必须更改我的代码，以便我的 spark 查询将选择所有列，而不是一组特定的列。（喜欢使用 ）。以前，当我有一组特定的列时，我很...

我有一个需要选择的列列表。我有此列表中每列的字段名称，因此很容易选择。 public Column[] getSelectColumns() { return new Column[]{ col...

我有数据帧，我想将其另存为多个xml文件。这是我的代码： employees .repartition(col("first_name")) .write() .option("maxRec...

例如，我可以从当前页面重定向到 google.com 吗？ 我尝试将方法重定向和标头与 Location 一起使用。 是否可以以某种方式实现重定向到另一个网站，或者仅实现路径 （/page1 ->...

Spark Java sum 给出的值不正确 Java 示例代码如下 List<Double> points = Arrays.asList(-6221.4, 6380.46); Dataset<...