Samza框架-----学习笔记

Samza框架-----学习笔记 基本概念: 作业:是对一组输入流进行处理转化成输出流的程序。 分区: Samza的流数据单位既不是Storm中的元组,也不是Spark Streaming中的DStream,而是一条条消息; Samza中的每个流都被分割成一个或多个分区,对于流里的每一个分区而言,都是一个有序的消息序列,后续到达的消息会根据一定规则被追加到其中一个分区里; 任务: 一个作业会被进一
相关文章
相关标签/搜索