有 Java 编程相关的问题?

你可以在下面搜索框中键入要查询的问题!

java组织。阿帕奇。火花sql。排到波乔

我正在尝试开发一个接受复杂数据类型(struct)并转换为字符串的UDF

下面是我的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;

}

子项目1:

@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
public class SubPojo1 {

    private Set<String> ids;
}

子项目2:

@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
public class SubPojo2 {
    private SubPojo3 sp3;
}

行类型(复杂结构类型)的UDF参数是基于MyPOJO生成的;如何将Row反序列化回MyPOJO。我知道我可以在编码器的帮助下创建一个基于POJO的数据帧,但这里我不想创建一个数据帧,只想从org创建一个POJO。阿帕奇。火花sql。划船


共 (0) 个答案