批处理数据流框架和模式
批处理环境提供批处理数据流 (BDS) 框架,其中包含可与流(例如文本、字节、数据库和数据集)配合使用的预先构建的代码。可以实现一个接口,在该接口中添加用于处理流的业务逻辑。预先构建的代码可以管理各项操作(例如,打开/关闭检查点以及对检查点进行外部化/内部化)。
BDS 框架模式
BDS 框架模式是一个适用于特定数据流类型的简单 Java™ TM 接口,用户实现该接口来插入业务逻辑。对于每个模式,BDS 框架具有多个支持类,这些类执行与流管理相关的大多数普通任务。下表显示批处理环境提供的模式:
模式名称 | 描述 | 支持类 |
---|---|---|
用于通过 JDBC 连接从数据库检索数据。 |
|
|
用于通过 JDBC 连接向数据库写入数据。 |
|
|
用于实现使用存储过程通过 JDBC 连接处理数据的业务逻辑 |
|
|
用于实现使用存储过程向 JDBC 连接输出数据的业务逻辑 |
|
|
用于从文件读取字节数据。 |
FileByteReader |
|
用于向文件写入字节数据。 |
FileByteWriter |
|
用于读取文本文件。 |
TextFileReader |
|
用于写入文本文件。 |
TextFileWriter |
|
![]() |
![]() 用于读取 z/OS 数据集。 |
![]()
|
![]() |
![]() 用于写入 z/OS 数据集。 |
![]()
|
用于使用配置的 JPA 提供程序从数据库检索数据。 |
JPAReader |
|
用于通过 Java Persistence API (JPA) 连接向数据库写入数据。 |
JPAWriter |
BDS 框架步骤
通过执行与步骤管理相关的簿记任务以及将业务逻辑委托给用户实现的类,BDS 框架步骤可最大程度减少创建批处理步骤所需的工作量。
步骤 | 描述 |
---|---|
使用一个输入流和一个输出流的简单步骤。 |
|
使用一个输入流、一个输出流和一个错误流的简单步骤。 |
ThresholdPolicies
步骤 | 描述 |
---|---|
此策略提供 ThresholdPolicy 接口的批处理实现。 |
|
此策略提供 ThresholdPolicy 接口的批处理实现。 |