O Compute Grid fornece uma estrutura de Batch Data Stream (BDS) que inclui código pré-construído para funcionar com fluxos populares como texto, byte, banco de dados, conjuntos de dados, etc. É possível implementar uma interface onde a lógica de negócios para processar o fluxo é incluída. O código pré-construído gerencia os pontos de verificação de abertura, fechamento, externalização/internalização, etc.
Você poderá usar este recurso, se tiver a Versão 6.1.0.3 ou posterior instalada.
Um padrão de estrutura do BDS é uma interface Java TM simples para um tipo específico de fluxo de dados que um usuário implementa para inserir a lógica de negócios. A estrutura do BDS tem várias classes de suporte para cada padrão que executa a maioria das tarefas rotineiras relacionadas ao gerenciamento de fluxo. A seguinte tabela mostra os padrões fornecidos pelo Compute Grid:
Nome do padrão | Descrição | Classes de Suporte |
---|---|---|
Usadas para recuperar dados de um banco de dados que usam uma conexão JDBC. |
|
|
Usado para gravar dados em um banco de dados que usa uma conexão JDBC. |
|
|
Usado para ler dados de bytes de um arquivo. |
FileByteReader |
|
Usado para gravar dados de bytes de um arquivo. |
FileByteWriter |
|
Usado para ler um arquivo de texto. |
TextFileReader |
|
Usado para gravar em um arquivo de texto. |
TextFileWriter |
|
Usado para ler um conjunto de dados z/OS. |
|
|
Usado para gravar em um conjunto de dados z/OS. |
|
|
Usado para recuperar dados de um banco de dados que usa OpenJPA |
JPAReader |
|
Usado par gravar dados em um banco de dados que usa a conexão Java Persistence API (JPA). |
JPAWriter |
As etapas da estrutura do BDS minimizam a quantidade de trabalho necessário para criar uma nova etapa em lote, executando as tarefas de escrituração contábil relacionadas ao gerenciamento de etapas e delegando a lógica de negócios a uma classe implementada pelo usuário.
Etapa | Descrição |
---|---|
Uma etapa simples que usa um fluxo de entrada e um fluxo de saída. |
|
Uma etapa simples que usa um fluxo de entrada, um fluxo de saída e um fluxo de erro. |
Etapa | Descrição |
---|---|
Essa política fornece uma implementação do Compute Grid da interface ThresholdPolicy. |
|
Essa política fornece uma implementação do Compute Grid da interface ThresholdPolicy. |