PartitionRecord 2025.5.31.15¶
Pacote¶
org.apache.nifi | nifi-standard-nar
Descrição¶
Divide, ou particiona, dados orientados a registros com base nos campos configurados nos dados. Uma ou mais propriedades devem ser adicionadas. O nome da propriedade é o nome de um atributo a ser adicionado. O valor da propriedade é um RecordPath para avaliar em relação a cada registro. Dois registros irão para o mesmo FlowFile de saída somente se tiverem o mesmo valor para cada um dos RecordPaths. Como sabemos que todos os registros em um determinado FlowFile de saída têm o mesmo valor para os campos especificados pelo RecordPath, um atributo é adicionado para cada campo. Consulte Detalhes adicionais na página Uso para obter mais informações e exemplos.
Requisito de entrada¶
REQUIRED
Oferece suporte a propriedades dinâmicas confidenciais¶
falso
Propriedades¶
Propriedade |
Descrição |
|---|---|
record-reader |
Especifica o Controller Service a ser usado para ler os dados recebidos |
record-writer |
Especifica o Controller Service a ser usado para gravar os registros |
Relações¶
Nome |
Descrição |
|---|---|
failure |
Se um FlowFile não puder ser particionado do formato de entrada configurado para o formato de saída configurado, o FlowFile inalterado será encaminhado para essa relação |
original |
Depois que todos os registros em um FlowFile de entrada tiverem sido particionados, o FlowFile original será encaminhado para essa relação. |
success |
FlowFiles que forem particionados com sucesso serão roteados 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 |
fragment.identifier |
Todos os FlowFiles particionados produzidos a partir do mesmo FlowFile pai terão o mesmo UUID gerado aleatoriamente adicionado para esse atributo |
fragment.index |
Um número sequencial que indica a ordem dos FlowFiles particionados criados a partir de um único FlowFile pai |
fragment.count |
O número de FlowFiles particionados gerados a partir do FlowFile pai |
segment.original.filename |
O nome de arquivo do FlowFile pai |
<nome da propriedade dinâmica> |
Para cada propriedade dinâmica adicionada, um atributo pode ser adicionado ao FlowFile. Consulte a descrição de Propriedades dinâmicas para obter mais informações. |
Casos de uso¶
Separe os registros em FlowFiles separados para que todos os registros no FlowFile tenham o mesmo valor para um determinado campo ou conjunto de campos. |
Separe os registros com base na adesão ou não adesão a um critério específico |