论文概要 该论文是Spark团队在2018年发表的一篇基于Spark引擎之上新构建的一套Streaming api...[作者空间]
根据集群的生命周期、资源隔离方式和应用程序的main()方法执行位置(client或者JobManager)可以将...[作者空间]
Flink集群架构 Flink采用Master-Slave架构，其中JobManager作为集群Master节点，...[作者空间]
快照策略(SnapshotStrategy) Flink的检查点机制是建立在分布式一致快照之上的，从而实现数据处理...[作者空间]
Flink系统组成 Flink是一个分层系统，从下到上分为：系统部署层、任务运行层、API层以及基于API开发的通...[作者空间]
Flink API介绍 Flink提供了三层API，每层在简洁性和表达性之间进行了不同的权衡。 ProcessFu...[作者空间]
Flink作为一个分布式流式计算引擎，需要计算资源才可以执行应用程序。Flink能够与目前所有通用的资源管理框架集...[作者空间]
项目构建 项目模板 Flink应用项目可以使用Maven或SBT来构建项目，Flink针对这些构建工具提供了相应项...[作者空间]
Trident是什么 Trident是Storm上的高层次抽象，它能够在提供高吞吐量的能力同时(每秒几百万消息)，...[作者空间]
Storm架构 Storm是一个分布式、可靠的实时计算系统。与Hadoop不同的是，它采用流式的消息处理方法，对于...[作者空间]
