文件名称:samza:Apache Samza的镜像
文件大小:11.83MB
文件格式:ZIP
更新时间:2024-02-26 15:39:40
scala big-data samza ScalaJava
什么是Samza? 是一个分布式流处理框架。 它使用进行消息传递,并使用提供容错,处理器隔离,安全性和资源管理。 Samza的主要功能包括: 简单的API:与大多数低级消息传递系统API不同,Samza提供了一个非常简单的基于回调的“过程消息” API,与MapReduce相当。 托管状态: Samza管理快照和流处理器状态的还原。 重新启动处理器后,Samza会将其状态恢复为一致的快照。 Samza旨在处理大量状态(每个分区许多GB)。 容错能力:每当群集中的计算机发生故障时,Samza都会与YARN一起将您的任务透明地迁移到另一台计算机。 耐用性: Samza使用Kafka保证