小编Asl*_*lan的帖子

将 Spark DataSet<ROW> 转换为 Java Pojo 类

我正在尝试将 DataSet 转换为 java 对象。架构就像

root
 |-- deptId: long (nullable = true)
 |-- depNameName: string (nullable = true)
 |-- employee: array (nullable = true)
 |    |-- element: struct (containsNull = true)
 |    |    |-- firstName: string (nullable = true)
 |    |    |-- lastName: string (nullable = true)
 |    |    |-- phno: Long (nullable = true)
 |    |    |    |-- element: integer (containsNull = true)
Run Code Online (Sandbox Code Playgroud)

我创建了 pojo 类 Like。

class Department {
  private Long deptId;
  private String depName;
  private List<Employee> employess; …
Run Code Online (Sandbox Code Playgroud)

java-8 apache-spark apache-spark-sql

6
推荐指数
0
解决办法
4911
查看次数

标签 统计

apache-spark ×1

apache-spark-sql ×1

java-8 ×1