【问题标题】:Spark Java - How do I iterate rows in dataframe Dataset<Row>, and add values of one column to an ArraylistSpark Java - 如何迭代数据帧 Dataset<Row> 中的行,并将一列的值添加到 Arraylist
【发布时间】:2018-09-11 11:55:11
【问题描述】:

我有一个Dataset&lt;Row&gt;,在Java 中包含3 columns。我想迭代它的行,然后将此列的值添加到ArrayList。谁能帮帮我?

请注意我在Java 工作。

谢谢。

【问题讨论】:

  • 为什么不arrayList.addAll(dataset.collect());
  • 我会试试@ErnestKiwele。

标签: java apache-spark spark-dataframe apache-spark-mllib


【解决方案1】:

你也可以使用 dataset.forEach(row -> syso(row));

【讨论】:

  • 什么是syso
  • System.out.println
【解决方案2】:

谢谢欧内斯特·基维尔。

它以这种方式工作:

List<Row> arrayList= new ArrayList<>();
arrayList=dataset.collectAsList();

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2018-10-01
    • 1970-01-01
    • 2016-05-22
    • 2020-05-11
    • 2020-01-06
    • 2018-10-02
    相关资源
    最近更新 更多