JavaFlink详细学习代码资料

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

【相关推荐】



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

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

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

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

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


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