JoltTransformRecord 2025.5.31.15¶
Pacote¶
org.apache.nifi | nifi-jolt-nar
Descrição¶
Aplica uma especificação JOLT a cada registro no payload do FlowFile. Um novo FlowFile é criado com conteúdo transformado e é encaminhado à relação “success”. Se a transformação falhar, o FlowFile original será encaminhado para a relação “failure”.
Requisito de entrada¶
REQUIRED
Oferece suporte a propriedades dinâmicas confidenciais¶
falso
Propriedades¶
Propriedade |
Descrição |
|---|---|
Diretório de módulos personalizados |
Lista separada por vírgulas de caminhos para arquivos e/ou diretórios que contêm módulos com transformações personalizadas (que não estão incluídos no caminho de classe do NiFi). |
Nome da classe de transformação personalizada |
Nome de classe totalmente qualificado para transformação personalizada |
Especificação Jolt |
Especificação Jolt para transformação de dados JSON. O valor dessa propriedade pode ser o texto de uma especificação Jolt ou o caminho para um arquivo que contenha uma especificação Jolt. A “especificação Jolt” deve ser definida, ou o valor será ignorado se a transformação Jolt Sort for selecionada. |
Transformação Jolt |
Especifica a transformação Jolt que deve ser usada com a especificação fornecida. |
Tamanho do cache de transformação |
A compilação de uma transformação Jolt pode ser bastante cara. O ideal é que isso seja feito apenas uma vez. No entanto, se a linguagem de expressão for usada na transformação, talvez seja necessária uma nova transformação para cada FlowFile. Esse valor controla quantas dessas transformações são armazenadas em cache na memória para evitar a necessidade de compilar a transformação todas as vezes. |
jolt-record-record-reader |
Especifica o Controller Service a ser usado para analisar os dados de entrada e determinar o esquema dos dados. |
jolt-record-record-writer |
Especifica o Controller Service a ser usado para gravar os registros |
Relações¶
Nome |
Descrição |
|---|---|
failure |
Se um FlowFile falhar no processamento por qualquer motivo (por exemplo, os registros FlowFile não podem ser analisados), ele será encaminhado para essa relação |
original |
O FlowFile original que foi transformado. Se o FlowFile falhar no processamento, nada será enviado a essa relação |
success |
O FlowFile com conteúdo transformado será encaminhado para essa relação |
Grava atributos¶
Nome |
Descrição |
|---|---|
record.count |
O número de registros em uma FlowFile de saída |
mime.type |
O tipo MIME que o Record Writer configurado indica ser apropriado |