将Java Spark数据框架转换为json值

vbopmzt1 于 2022-11-16 发布在 Apache

关注(0)|答案(1)|浏览(205)

我有一个数据框，它有3列a，B，c。
我想要一个如下所示的JSON对象

{ 
     predictions : [
          {
               a:1,b:1,c:1
          },
          {
               a:2,b:2,c:3
          },...
    ]
}

在这里，原始 Dataframe 的每一行都变成了一个json对象，被塞进了一个高级的对象预测中。理想情况下，我可以对每一个对象进行分区，这样预测列表的长度就不会超过100。有人有干净的方法来做到这一点吗？我觉得我遗漏了一些明显的东西

1条答案

大概有这样一个模式：

public class Data {
    List<Dataframe> predictions;

    // ...
}

public class Dataframe {
    int a;
    int b;
    int c;

    // ...
}

您可以收集 Dataframe （最多100个），然后使用任何库（如Jackson）创建JSON数据。