批处理数据流框架和模式

批处理环境提供批处理数据流 (BDS) 框架,其中包含可与流(例如文本、字节、数据库和数据集)配合使用的预先构建的代码。可以实现一个接口,在该接口中添加用于处理流的业务逻辑。预先构建的代码可以管理各项操作(例如,打开/关闭检查点以及对检查点进行外部化/内部化)。

BDS 框架模式

BDS 框架模式是一个适用于特定数据流类型的简单 Java™ TM 接口,用户实现该接口来插入业务逻辑。对于每个模式,BDS 框架具有多个支持类,这些类执行与流管理相关的大多数普通任务。下表显示批处理环境提供的模式:

表 1. BDS 框架模式. 该表包括模式名称、描述和支持类。
模式名称 描述 支持类

JDBCReaderPattern

用于通过 JDBC 连接从数据库检索数据。

  • LocalJDBCReader
  • JDBCReader
  • CursorHoldableJDBCReader

JDBCWriterPattern

用于通过 JDBC 连接向数据库写入数据。

  • LocalJDBCWriter
  • JDBCWriter

JDBCCallableStatementReaderPattern

用于实现使用存储过程通过 JDBC 连接处理数据的业务逻辑

  • JDBCCallableStatementReader
  • LocalJDBCCallableStatementReader

JDBCCallableStatementWriterPattern

用于实现使用存储过程向 JDBC 连接输出数据的业务逻辑

  • JDBCCallableStatementWriter
  • LocalJDBCCallableStatementWriter

ByteReaderPattern

用于从文件读取字节数据。

FileByteReader

ByteWriterPattern

用于向文件写入字节数据。

FileByteWriter

FileReaderPattern

用于读取文本文件。

TextFileReader

FileWriterPattern

用于写入文本文件。

TextFileWriter

[z/OS]

RecordOrientedDatasetReaderPattern

[z/OS]

用于读取 z/OS 数据集。

[z/OS]
  • ZFileStreamOrientedTextReader
  • ZFileStreamOrientedByteReader
  • ZFileRecordOrientedDataReader
[z/OS]

RecordOrientedDataSetWriterPattern

[z/OS]

用于写入 z/OS 数据集。

[z/OS]
  • ZFileStreamOrientedTextWriter
  • ZFileStreamOrientedByteWriter
  • ZFileRecordOrientedDataReader

JPAReaderPattern

用于使用配置的 JPA 提供程序从数据库检索数据。

JPAReader

JPAWriterPattern

用于通过 Java Persistence API (JPA) 连接向数据库写入数据。

JPAWriter

BDS 框架步骤

通过执行与步骤管理相关的簿记任务以及将业务逻辑委托给用户实现的类,BDS 框架步骤可最大程度减少创建批处理步骤所需的工作量。

表 2. BDS 框架步骤. 该表包括框架步骤和描述。
步骤 描述

实现通用批处理步骤 (GenericXDBatchStep)

使用一个输入流和一个输出流的简单步骤。

实现容错步骤 (ThresholdBatchStep)

使用一个输入流、一个输出流和一个错误流的简单步骤。

ThresholdPolicies

表 3. ThresholdPolicies. 该表包括步骤和描述。
步骤 描述

声明基于记录的阈值策略 (RecordBasedThresholdPolicy)

此策略提供 ThresholdPolicy 接口的批处理实现。

声明基于百分比的阈值策略 (PercentageBasedThresholdPolicy)

此策略提供 ThresholdPolicy 接口的批处理实现。


指示主题类型的图标 概念主题



时间戳记图标 最近一次更新时间: last_date
http://www14.software.ibm.com/webapp/wsbroker/redirect?version=cord&product=was-nd-mp&topic=cgrid_btchpttrnover
文件名:cgrid_btchpttrnover.html