我试图开发一个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