自定义带有状态的udf

自定义UDF 实现CheckpointedFunction 伪代码如下 发现并没有执行initializeState public class ClusterInfoCollectUdf extends ScalarFunction implements CheckpointedFunction { private static final LoggerLOGGER = LoggerFactory.getLogger(ClusterInfoCollectUdf.class); private transient

如何自定义带有状态的UDF

自定义UDF 实现CheckpointedFunction 伪代码如下 发现并没有执行initializeState public class ClusterInfoCollectUdf extends ScalarFunction implements CheckpointedFunction { private static final LoggerLOGGER = LoggerFactory.getLogger(ClusterInfoCollectUdf.class); private transient