GitHub源码(https://github.com/echo9509/flink-learning)
流处理就是我们对流动的数据(无限的数据)进行处理,通常我们会提前设置好算子(也就是你的处理逻辑),当数据到达后对数据进行处理。
作者本人之所以写Flink是因为最近在做一些实时监控的东西,需要对数据流进行实时处理并计算然后投递到后续的存储,因此最近一段时间会持续研究Flink和监控的一些东西,也希望有Flink开发经验、监控系统开发经验的或对其感...
使用flink kubernetes operator创建flink任务,将flink日志通过sidecar方式发送到es相关配置
Uber 拥有世界上最大的 Kafka 集群,每天处理数万亿条消息和几个 PB 的数据。如图 1 所示,Kafka 现在成了 Uber 技术栈的基石,我们基于这个基石构建了一个复杂的生态系统,为大量不同的工作流提供支持。其中包含了一个用于...
流处理系统由于需要支持无限数据集的处理,一般采用一种数据驱动的处理方式。它会提前设置一些算子,然后等到数据到达后对数据进行处理。
Apache Flink(德语:快速灵巧,原德国柏林大学基金会项目)是一个框架和分布式处理引擎,用于对无界和有界数据流进行状态计算。ms级别水平。data flow+event sequence。...
前段时间详细地阅读了 《Apache Flink的流处理》 这本书,作者是 Fabian Hueske&Vasiliki Kalavri,国内崔星灿翻译的,这本书非常详细、全面得介绍了Flink流处理,并且以气象数据的例子讲解其中的使用,我把其中一些比较重要的...
本期我们带大家回顾一下无倦同学的直播分享《ChunJun 类加载器隔离》,ChunJun 类加载器隔离的方案是我们近期探索的一个新方案,这个方案目前还不是非常成熟,希望能借由此次分享与大家一起探讨下这方案,如果大家有一些新的...
/data1/nfs/rootfs——NFS服务器端的目录,用于与nfs客户端共享