文章 2024-06-15 来自:开发者社区

实时计算 Flink版产品使用问题之holo的io以及cpu使用较为稳定,sink端busy一直在20%左右,有时候50%,该如何优化

问题一:Flink的LOOKUP JOIN 支持子查询吗? Flink的LOOKUP JOIN 支持子查询吗? 参考答案: 关于本问题的更多回答可点击进行查看...

实时计算 Flink版产品使用问题之holo的io以及cpu使用较为稳定,sink端busy一直在20%左右,有时候50%,该如何优化
问答 2021-12-07 来自:开发者社区

写HBase慢造成消息堆积,有没有异步IO可以用于sink或者outputFormat的方法?

业务场景中,需要将处理后的消息写入到HBase中,由于写入HBase慢,引起消息堆积。 通过Stream API 有没有方法可以异步批量发送? 谢谢!*来自志愿者整理的flink邮件归档

问答 2019-12-09 来自:开发者社区

请问一下,flink将结果sink到redis里面会不会对存储的IO造成很大的压力,如何批量的输出结

请问一下,flink将结果sink到redis里面会不会对存储的IO造成很大的压力,如何批量的输出结果呢? 本问题来自阿里云开发者社区的【11大垂直技术领域开发者社群】。 点击这里欢迎加入感兴趣的技术领域群。

文章 2016-04-18 来自:开发者社区

泛函编程(36)-泛函Stream IO:IO数据源-IO Source & Sink

 上期我们讨论了IO处理过程:Process[I,O]。我们说Process就像电视信号盒子一样有输入端和输出端两头。Process之间可以用一个Process的输出端与另一个Process的输入端连接起来形成一串具备多项数据处理功能的完整IO过程。但合成的IO过程两头输入端则需要接到一个数据源,而另外一端则可能会接到一个数据接收设备如文件、显示屏等。我们在这篇简单地先介绍一下IO数据源...

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。