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) 个答案