将Spark org.apache.spark.sql.Row转换为POJO

0 人关注

我试图开发一个UDF,接受一个复杂的数据类型(struct)并将其转换为字符串。

下面是我的UDF的样子。

protected UDF1<Row, String> convertComplexDataType() {
    return (Row row) -> {
        return "....";

我也有一个POJO(这个复杂的数据类型是基于它的)。

import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
public class MyPOJO {
    private SubPojo1 sp1;
    private SubPojo2 sp2;
    private Long version;

SubPojo1:

@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
public class SubPojo1 {
    private Set<String> ids;

SubPojo2:

@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor