Java Spark: Как создать плоскую карту для набора данных и предоставить новую схему для последующего группирования?

#java #apache-spark #apache-spark-sql Вопрос: У меня есть следующий код: public static void main(String[] args) { Dataset<Row> myDataset = spark.read().parquet(PATH); Dataset<Row> groupedDataset = myDataset .flatMap((FlatMapFunction<Row, Row>) (row) -> flatMapFunc(row), Encoders.bean(Row.class)) .groupBy("group_id")…