flink 的学习代码有java的吗,我看到您写的都是scala的flink 的学习代码有java的吗,我看到您写的都是scala的 [捂脸笑]
1条回答 默认 最新
关注 【相关推荐】
- 你可以参考下这篇文章:java编写flink任务示例
- 除此之外, 这篇博客: flink 学习(一)java 整合 flink中的 一、流、批处理 部分也许能够解决你的问题, 你可以仔细阅读以下内容或跳转源博客中阅读:
有界流:有定义流的开始,但没有定义流的结束。它们会无休止地产生数据。无界流的数据必须持续处理,即数据被摄取后需要立刻处理。我们不能等到所有数据都到达再处理,因为输入是无限的,在任何时候输入都不会完成。
无界流:有定义流的开始,也有定义流的结束。有界流可以在摄取所有数据后再进行计算。有界流所有数据可以被排序,所以并不需要有序摄取。
流处理:无界流通常被称为流处理。当一条数据被处理完成后,序列化到缓存中,然后立刻通过网络传输到下一个节点,由下一个节点继续处理。数据是一条一条的处理,实时性高。
批处理:有界流处理通常被称为批处理。当一条数据被处理完成后,序列化到缓存中,并不会立刻通过网络传输到下一个节点,当缓存写满,就持久化到本地硬盘上,当所有数据都被处理完成后,才开始将处理后的一批数据通过网络传输到下一个节点。数据是一批一批处理,实时性低。
如果你已经解决了该问题, 非常希望你能够分享一下解决方案, 写成博客, 将相关链接放在评论区, 以帮助更多的人 ^-^解决 无用评论 打赏 举报
悬赏问题
- ¥15 odoo17处理受托加工产品
- ¥15 如何用MATLAB编码图三的积分
- ¥15 为什么我安装了Homebrew之后,无法像官网的那样通过执行命令安装Watchman
- ¥15 圆孔衍射光强随孔径变化
- ¥15 MacBook pro m3max上用vscode运行c语言没有反应
- ¥15 ESP-PROG配置错误,ALL ONES
- ¥15 结构功能耦合指标计算
- ¥50 AI大模型精调(百度千帆、飞浆)
- ¥15 非科班怎么跑代码?如何导数据和调参
- ¥15 福州市的全人群死因监测点死亡原因报表