2201_75324310 2023-09-02 15:36 采纳率: 0%
浏览 4

JavaFlink详细学习代码资料

flink 的学习代码有java的吗,我看到您写的都是scala的flink 的学习代码有java的吗,我看到您写的都是scala的 [捂脸笑]

  • 写回答

1条回答 默认 最新

  • CSDN-Ada助手 CSDN-AI 官方账号 2023-09-02 19:00
    关注

    【相关推荐】



    • 你可以参考下这篇文章:java编写flink任务示例
    • 除此之外, 这篇博客: flink 学习(一)java 整合 flink中的 一、流、批处理 部分也许能够解决你的问题, 你可以仔细阅读以下内容或跳转源博客中阅读:

              有界流:有定义流的开始,但没有定义流的结束。它们会无休止地产生数据。无界流的数据必须持续处理,即数据被摄取后需要立刻处理。我们不能等到所有数据都到达再处理,因为输入是无限的,在任何时候输入都不会完成。

              无界流:有定义流的开始,也有定义流的结束。有界流可以在摄取所有数据后再进行计算。有界流所有数据可以被排序,所以并不需要有序摄取。

              流处理:无界流通常被称为流处理。当一条数据被处理完成后,序列化到缓存中,然后立刻通过网络传输到下一个节点,由下一个节点继续处理。数据是一条一条的处理,实时性高。

              批处理:有界流处理通常被称为批处理。当一条数据被处理完成后,序列化到缓存中,并不会立刻通过网络传输到下一个节点,当缓存写满,就持久化到本地硬盘上,当所有数据都被处理完成后,才开始将处理后的一批数据通过网络传输到下一个节点。数据是一批一批处理,实时性低。


    如果你已经解决了该问题, 非常希望你能够分享一下解决方案, 写成博客, 将相关链接放在评论区, 以帮助更多的人 ^-^
    评论

报告相同问题?

问题事件

  • 创建了问题 9月2日

悬赏问题

  • ¥15 odoo17处理受托加工产品
  • ¥15 如何用MATLAB编码图三的积分
  • ¥15 为什么我安装了Homebrew之后,无法像官网的那样通过执行命令安装Watchman
  • ¥15 圆孔衍射光强随孔径变化
  • ¥15 MacBook pro m3max上用vscode运行c语言没有反应
  • ¥15 ESP-PROG配置错误,ALL ONES
  • ¥15 结构功能耦合指标计算
  • ¥50 AI大模型精调(百度千帆、飞浆)
  • ¥15 非科班怎么跑代码?如何导数据和调参
  • ¥15 福州市的全人群死因监测点死亡原因报表