job 领域api
- 参考图
- 说明
通用的处理流程为:
- 通过包含JobParameters 参数的JobBuilder创建job
- 通过JobExecutor 执行job
- 通过JobReport获取job运行的状态
record 以及batch api
easy-batch 提供了一个通用的record 以及batch 模型,简化了数据的处理,record可以是各类文件
- 参考
- record 接口
public interface Record<P> {
/** Return the record header */
Header getHeader();
/** Return the record payload */
P getPayload();
}
- 说明
record 包含了header 以及payload,header包含了一些元数据描述
payload 为我们需要处理的数据 - record 的处理
参考如下: