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

基本概念： 作业：是对一组输入流进行处理转化成输出流的程序。 分区： Samza的流数据单位既不是Storm中的元组，也不是Spark Streaming中的DStream，而是一条条消息； Samza中的每个流都被分割成一个或多个分区，对于流里的每一个分区而言，都是一个有序的消息序列，后续到达的消息会根据一定规则被追加到其中一个分区里； 任务： 一个作业会被进一步分割成多个任务（Task）来执行

>>阅读原文<<