The batch environment provides a batch data stream (BDS) framework that includes pre-built code to work with streams such as text, byte, database, and data sets. You can implement an interface where the business logic for processing the stream is added. The pre-built code manages actions such as opening, closing, and externalizing and internalizing checkpoints.
A BDS framework pattern is a simple Java TM interface for a particular type of data stream that a user implements to insert business logic. The BDS framework has several supporting classes for each pattern that do most of the mundane tasks related to stream management. The following table shows the patterns that the batch environment provides:
Pattern name | Description | Supporting classes |
---|---|---|
Used to retrieve data from a database using a JDBC connection. |
|
|
Used to write data to a database using a JDBC connection. |
|
|
![]() JDBCCallableStatementReaderPattern ![]() |
![]() Used to implement the business logic of processing data from a JDBC connection using a stored procedure ![]() |
![]()
![]() |
![]() JDBCCallableStatementWriterPattern ![]() |
![]() Used to implement the business logic of outputting data to a JDBC connection using a stored procedure ![]() |
![]()
![]() |
Used to read byte data from a file. |
FileByteReader |
|
Used to write byte data to a file. |
FileByteWriter |
|
Used to read a text file. |
TextFileReader |
|
Used to write to a text file. |
TextFileWriter |
|
Used to retrieve data from a database using OpenJPA |
JPAReader |
|
Used to write data to a database using a Java Persistence API (JPA) connection. |
JPAWriter |
BDS framework steps minimize the amount of work to create a batch step by performing the bookkeeping tasks related to step management and delegating the business logic to a class implemented by the user.
Step | Description |
---|---|
A simple step that uses one input and one output stream. |
|
A simple step that uses one input, one output stream, and one error stream. |
Step | Description |
---|---|
Declaring the record based threshold policy (RecordBasedThresholdPolicy) |
This policy provides a batch implementation of the ThresholdPolicy interface. |
Declaring the percentage-based threshold policy (PercentageBasedThresholdPolicy) |
This policy provides a batch implementation of the ThresholdPolicy interface |