在Samza中,作业由一个或多个任务组成。每个任务负责处理输入数据流的一部分并生成输出数据流。工作的组成如下:
输入数据流:作业从一个或多个输入数据流中读取数据。
处理逻辑:Job包含处理输入数据流的逻辑,通常由用户定义的逻辑来实现。
输出数据流:作业将处理后的数据写入一个或多个输出数据流。
任务:作业中的每个任务负责处理输入数据流中的部分数据并生成输出数据流。您可以有一个或多个任务来组成一个作业。
总之,一个作业由输入数据流、处理逻辑、输出数据流和用于处理数据流的多个任务组成。
以上内容来自互联网,不代表本站全部观点!欢迎关注我们:zhujipindao。com
评论前必须登录!
注册