breeze_lsw

Delta Lake 在说 Delta Lake 之前，要先提一下 Data Lake ，Data Lake 的主要思想是将企业中的所有数据进行统一管理。例如基于 Hadoo...

shengjk1

之前一直有个疑问，如果consumer.setStartFromLatest()以及kafkaProperties.put("auto.offset.reset", "ear...

生活的探路者

2018年08月17日 11:38:25列国周游阅读数：284 版权声明：著作权归作者所有。 商业转载请联系作者获得授权，非商业转载请注明出处。 https://blog.c...

尼小摩

继上文Flink 原理与实现：架构和拓扑概览中介绍了Flink的四层执行图模型，本文将主要介绍 Flink 是如何根据用户用Stream API编写的程序，构造出一个代表拓扑...