Index

A B C D E G H I L M N P R S T U V X Z 
All Classes and Interfaces|All Packages

A

atualizadas() - Method in record class br.com.xadm.ingestao.UpsertResultado
Returns the value of the atualizadas record component.

B

br.com.xadm.ingestao - package br.com.xadm.ingestao
Seam de ingestão XLS/CSV (ADR 0019, raiz/001 Fase 5, plano 003 T6): o esqueleto agnóstico de domínio + as SPIs que os apps implementam.
BulkUpsertStrategy<T> - Interface in br.com.xadm.ingestao
SPI do motor de upsert em lote.
bytes() - Method in record class br.com.xadm.ingestao.ZipXlsExtrator.EntradaXls
Returns the value of the bytes record component.

C

coarse(int, int) - Static method in record class br.com.xadm.ingestao.UpsertResultado
Fábrica para engines que só sabem "quantas linhas mudaram" (executeBatch).
ConjuntoLote - Class in br.com.xadm.ingestao
Tabela xls_conjunto_lote: rastreia um lote de arquivos enviados juntos num .zip.
ConjuntoLote() - Constructor for class br.com.xadm.ingestao.ConjuntoLote
 
ConjuntoLoteRepository - Interface in br.com.xadm.ingestao
Persistência de ConjuntoLote (lote por zip).
ConjuntoLoteService - Class in br.com.xadm.ingestao
Coordena o ciclo de vida de um lote (.zip).
ConjuntoLoteService(ConjuntoLoteRepository, ContadorProcessamentosFinalizados, ResumoLoteNotificador) - Constructor for class br.com.xadm.ingestao.ConjuntoLoteService
 
contabilizarNaoProcessado(String) - Method in class br.com.xadm.ingestao.ConjuntoLoteService
Entrada do zip que não gerou processamento nem era duplicata-sucesso (rejeitada por tipo/magic, ou já em andamento): conta para o lote fechar mesmo assim.
ContadorProcessamentosFinalizados - Interface in br.com.xadm.ingestao
SPI de contagem de processamentos finalizados de um lote.
contarFinalizados(String) - Method in interface br.com.xadm.ingestao.ContadorProcessamentosFinalizados
Conta os processamentos do lote que já finalizaram.

D

DespachanteXlsProcessor - Class in br.com.xadm.ingestao
Despacha um arquivo para o XlsProcessor do seu tipo.
DespachanteXlsProcessor(List) - Constructor for class br.com.xadm.ingestao.DespachanteXlsProcessor
 

E

EntradaXls(String, byte[]) - Constructor for record class br.com.xadm.ingestao.ZipXlsExtrator.EntradaXls
Creates an instance of a EntradaXls record class.
enviadas() - Method in record class br.com.xadm.ingestao.UpsertResultado
Returns the value of the enviadas record component.
equals(Object) - Method in record class br.com.xadm.ingestao.ResultadoProcessamento.Ignorado
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class br.com.xadm.ingestao.ResultadoProcessamento.Sucesso
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class br.com.xadm.ingestao.UpsertResultado
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class br.com.xadm.ingestao.ZipXlsExtrator.EntradaXls
Indicates whether some other object is "equal to" this one.
extrair(byte[]) - Method in class br.com.xadm.ingestao.ZipXlsExtrator
Desempacota o zip e devolve suas entradas .xlsx (ignora diretórios, __MACOSX/ e temporários ~$).

G

getConjuntoId() - Method in class br.com.xadm.ingestao.ConjuntoLote
 
getCriadoEm() - Method in class br.com.xadm.ingestao.ConjuntoLote
 
getDuplicados() - Method in class br.com.xadm.ingestao.ConjuntoLote
 
getNaoProcessados() - Method in class br.com.xadm.ingestao.ConjuntoLote
 
getNotificadoEm() - Method in class br.com.xadm.ingestao.ConjuntoLote
 
getTotal() - Method in class br.com.xadm.ingestao.ConjuntoLote
 

H

hashCode() - Method in record class br.com.xadm.ingestao.ResultadoProcessamento.Ignorado
Returns a hash code value for this object.
hashCode() - Method in record class br.com.xadm.ingestao.ResultadoProcessamento.Sucesso
Returns a hash code value for this object.
hashCode() - Method in record class br.com.xadm.ingestao.UpsertResultado
Returns a hash code value for this object.
hashCode() - Method in record class br.com.xadm.ingestao.ZipXlsExtrator.EntradaXls
Returns a hash code value for this object.

I

Ignorado(String) - Constructor for record class br.com.xadm.ingestao.ResultadoProcessamento.Ignorado
Creates an instance of a Ignorado record class.
inalteradas() - Method in record class br.com.xadm.ingestao.UpsertResultado
Returns as linhas enviadas que não resultaram em alteração (idempotentes).
incrementarDuplicados(String) - Method in interface br.com.xadm.ingestao.ConjuntoLoteRepository
Conta um arquivo já existente (HTTP 200).
incrementarNaoProcessados(String) - Method in interface br.com.xadm.ingestao.ConjuntoLoteRepository
Conta uma entrada do zip que não gerou processamento nem era duplicata-sucesso.
inseridas() - Method in record class br.com.xadm.ingestao.UpsertResultado
Returns the value of the inseridas record component.

L

linhasEfetivas() - Method in record class br.com.xadm.ingestao.ResultadoProcessamento.Sucesso
Returns the value of the linhasEfetivas record component.
linhasEnviadas() - Method in record class br.com.xadm.ingestao.ResultadoProcessamento.Sucesso
Returns the value of the linhasEnviadas record component.
linhasRemovidas() - Method in record class br.com.xadm.ingestao.ResultadoProcessamento.Sucesso
Returns the value of the linhasRemovidas record component.
listSheetNames(byte[]) - Method in interface br.com.xadm.ingestao.XlsReader
Lista os nomes das abas do arquivo.

M

mais(UpsertResultado) - Method in record class br.com.xadm.ingestao.UpsertResultado
Soma duas métricas (acumular por tabela num processamento).
motivo() - Method in record class br.com.xadm.ingestao.ResultadoProcessamento.Ignorado
Returns the value of the motivo record component.

N

nome() - Method in record class br.com.xadm.ingestao.ZipXlsExtrator.EntradaXls
Returns the value of the nome record component.
notificarResumo(ConjuntoLote) - Method in interface br.com.xadm.ingestao.ResumoLoteNotificador
Notifica o resumo de um lote que acabou de fechar.

P

para(String) - Method in class br.com.xadm.ingestao.DespachanteXlsProcessor
Encontra o processador de um tipo.
periodoFim() - Method in record class br.com.xadm.ingestao.ResultadoProcessamento.Sucesso
Returns the value of the periodoFim record component.
periodoInicio() - Method in record class br.com.xadm.ingestao.ResultadoProcessamento.Sucesso
Returns the value of the periodoInicio record component.
processar(byte[], String, Consumer) - Method in interface br.com.xadm.ingestao.XlsProcessor
Processa o arquivo: lê (via XlsReader), mapeia para domínio e persiste (via BulkUpsertStrategy), devolvendo o resultado com métricas.

R

readDefaultSheet(byte[], BiConsumer) - Method in interface br.com.xadm.ingestao.XlsReader
Lê a aba default (primeira/única), entregando cada linha ao consumidor.
readFirstRowOfSheet(byte[], String) - Method in interface br.com.xadm.ingestao.XlsReader
Lê apenas a primeira linha de uma aba (detecção de tipo sem varredura completa).
readSheet(byte[], String, BiConsumer) - Method in interface br.com.xadm.ingestao.XlsReader
Lê uma aba pelo nome, entregando cada linha ao consumidor.
registrar(String, int) - Method in interface br.com.xadm.ingestao.ConjuntoLoteRepository
Cria o lote se ainda não existir (idempotente).
registrar(String, int) - Method in class br.com.xadm.ingestao.ConjuntoLoteService
Registra o lote na primeira chamada (idempotente).
registrarDuplicado(String) - Method in class br.com.xadm.ingestao.ConjuntoLoteService
Arquivo já existente no banco (HTTP 200): conta e verifica se o lote fechou.
registros() - Method in record class br.com.xadm.ingestao.ResultadoProcessamento.Sucesso
Returns the value of the registros record component.
removidas() - Method in record class br.com.xadm.ingestao.UpsertResultado
Returns the value of the removidas record component.
ResultadoProcessamento - Interface in br.com.xadm.ingestao
Resultado de um processamento de arquivo — carrega as métricas no retorno, eliminando os Consumer<...> callback que onpetro usava para acumular linhas_efetivas/linhas_removidas (over-eng menor do BI, R5).
ResultadoProcessamento.Ignorado - Record Class in br.com.xadm.ingestao
Arquivo ignorado por regra de negócio.
ResultadoProcessamento.Sucesso - Record Class in br.com.xadm.ingestao
Processamento concluído com sucesso.
ResumoLoteNotificador - Interface in br.com.xadm.ingestao
SPI de notificação do resumo de um lote fechado.

S

semPeriodo(int, int, int, int) - Static method in record class br.com.xadm.ingestao.ResultadoProcessamento.Sucesso
Sucesso sem período (tipos que não cobrem intervalo de datas).
setConjuntoId(String) - Method in class br.com.xadm.ingestao.ConjuntoLote
 
setCriadoEm(LocalDateTime) - Method in class br.com.xadm.ingestao.ConjuntoLote
 
setDuplicados(int) - Method in class br.com.xadm.ingestao.ConjuntoLote
 
setNaoProcessados(int) - Method in class br.com.xadm.ingestao.ConjuntoLote
 
setNotificadoEm(LocalDateTime) - Method in class br.com.xadm.ingestao.ConjuntoLote
 
setTotal(int) - Method in class br.com.xadm.ingestao.ConjuntoLote
 
Sucesso(int, LocalDate, LocalDate, int, int, int) - Constructor for record class br.com.xadm.ingestao.ResultadoProcessamento.Sucesso
Creates an instance of a Sucesso record class.

T

tentarNotificar(String, int) - Method in interface br.com.xadm.ingestao.ConjuntoLoteRepository
UPDATE atômico: retorna 1 só para o thread que completa o lote (duplicados + nao_processados + finalizados >= total), 0 para os demais.
tipo() - Method in interface br.com.xadm.ingestao.XlsProcessor
Chave do tipo de arquivo que este processador trata (ex.: "COMPRAS", "FATURAMENTO").
toString() - Method in record class br.com.xadm.ingestao.ResultadoProcessamento.Ignorado
Returns a string representation of this record class.
toString() - Method in record class br.com.xadm.ingestao.ResultadoProcessamento.Sucesso
Returns a string representation of this record class.
toString() - Method in record class br.com.xadm.ingestao.UpsertResultado
Returns a string representation of this record class.
toString() - Method in record class br.com.xadm.ingestao.ZipXlsExtrator.EntradaXls
Returns a string representation of this record class.
totalAlteracoes() - Method in record class br.com.xadm.ingestao.UpsertResultado
Returns o total de linhas efetivamente alteradas (inseridas + atualizadas + removidas).

U

upsertLote(List) - Method in interface br.com.xadm.ingestao.BulkUpsertStrategy
Persiste o lote de registros e devolve a métrica.
UpsertResultado - Record Class in br.com.xadm.ingestao
Métrica de um upsert em lote — superconjunto que serve as duas técnicas: executeBatch (onpetro, que só conhece enviadas/efetivas) e COPY+CTE RETURNING xmax=0 (vantroba, que separa inseridas/atualizadas/removidas).
UpsertResultado(int, int, int, int) - Constructor for record class br.com.xadm.ingestao.UpsertResultado
Creates an instance of a UpsertResultado record class.

V

VAZIO - Static variable in record class br.com.xadm.ingestao.UpsertResultado
Resultado vazio (nenhuma linha enviada).
verificarENotificar(String) - Method in class br.com.xadm.ingestao.ConjuntoLoteService
Verifica atomicamente se o lote fechou; o thread vencedor dispara o resumo.

X

XlsProcessor - Interface in br.com.xadm.ingestao
SPI do processador de um tipo de arquivo.
XlsReader - Interface in br.com.xadm.ingestao
SPI de leitura de planilha: transforma os bytes de um arquivo em linhas de String[], sem conhecimento de domínio.

Z

ZipXlsExtrator - Class in br.com.xadm.ingestao
Desempacota o .zip de lote em suas entradas .xlsx (o zip É o lote).
ZipXlsExtrator() - Constructor for class br.com.xadm.ingestao.ZipXlsExtrator
 
ZipXlsExtrator.EntradaXls - Record Class in br.com.xadm.ingestao
Uma entrada .xlsx do zip.
A B C D E G H I L M N P R S T U V X Z 
All Classes and Interfaces|All Packages