ExtractRecordSchema 2025.5.31.15

Pacote

org.apache.nifi | nifi-standard-nar

Descrição

Extrai o esquema de registro do FlowFile usando o Record Reader fornecido e grava-o no atributo avro.schema.

Tags

avro, csv, freeform, generic, json, record, schema, text, xml

Requisito de entrada

REQUIRED

Oferece suporte a propriedades dinâmicas confidenciais

falso

Propriedades

Propriedade

Descrição

cache-size

Especifica o número de esquemas a serem armazenados em cache. Esse valor deve refletir o número esperado de esquemas diferentes que podem estar nos FlowFiles de entrada. Isso garante uma recuperação mais eficiente dos esquemas e, portanto, o desempenho do processador.

record-reader

Especifica o Controller Service a ser usado para ler os dados recebidos

Relações

Nome

Descrição

failure

Se o esquema de registro do FlowFile não puder ser extraído do formato de entrada configurado, o FlowFile será encaminhado para essa relação

success

FlowFiles cujos esquemas de registros forem extraídos com sucesso serão encaminhados para essa relação

Grava atributos

Nome

Descrição

record.error.message

Esse atributo fornece, em caso de falha, a mensagem de erro encontrada pelo leitor.

avro.schema

Esse atributo fornece o esquema extraído do FlowFile de entrada usando o RecordReader fornecido.