批次資料串流架構和型樣

批次 環境提供批次資料串流 (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

用來從檔案讀取位元組資料。

檔案位元組讀取器

ByteWriterPattern

用來將位元組資料寫入檔案。

FileByteWriter

檔案 ReaderPattern

用來讀取文字檔。

TextFileReader

檔案寫入型樣

用來寫入文字檔。

TextFileWriter

JPAReaderPattern

用來使用 OpenJPA 從資料庫擷取資料

JPAReader

JPAWriterPattern

用來使用「Java 持續性 API (JPA)」連線將資料寫入資料庫。

JPAWriter

BDS 架構步驟

BDS 架構步驟透過執行與步驟管理相關的簿記作業,並將商業邏輯委派給使用者實作的類別,將建立批次步驟的工作量降到最低。

表 2. BDS 架構步驟 表格包含架構步驟和說明。
步驟 說明

實作一般批次步驟 (GenericXDBatchStep)

使用一個輸入及一個輸出串流的簡式步驟。

實作容錯步驟 (ThresholdBatchStep)

使用一個輸入、一個輸出串流及一個錯誤串流的簡式步驟。

ThresholdPolicies

表 3. ThresholdPolicies 表格包含步驟和說明。
步驟 說明

宣告記錄型臨界值原則 (RecordBasedThresholdPolicy)

此原則提供 批次 實作 ThresholdPolicy 介面。

宣告百分比型臨界值原則 (PercentageBasedThresholdPolicy)

此原則提供 批次 實作 ThresholdPolicy 介面