开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

在udf封装sink操作的这种做法,合规嘛?

在udf封装sink操作的这种做法,合规嘛

相当于流来驱动计算,但计算的内容可能已经不是流本身了 另外,可以在udf的open函数里,注册定时器嘛,利用flink做定时调度(窗口在flinkSQL里,不能对kafka这种数据源进行聚合),这种做法合规嘛

展开
收起
游客6vdkhpqtie2h2 2022-09-29 10:52:55 373 0
0 条回答
写回答
取消 提交回答

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关电子书

更多
Apache Flink 流式应用中状态的数据结构定义升级 立即下载
HBase2.0重新定义小对象实时存取 立即下载
大批量处理excel文件到ODPS中方案 立即下载