ScriptedPartitionRecord 2025.5.31.15¶

Pacote¶

org.apache.nifi | nifi-scripting-nar

Descrição¶

Recebe dados orientados a registros (ou seja, dados que podem ser lidos pelo Record Reader configurado) e avalia o script fornecido pelo usuário em relação a cada registro no FlowFile de entrada. Cada registro é então agrupado com outros registros que compartilham a mesma partição e um FlowFile é criado para cada grupo de registros. Dois registros compartilham a mesma partição se a avaliação do script resultar no mesmo valor de retorno para ambos. Elas serão consideradas como parte da mesma partição.

Tags¶

groovy, group, organize, partition, record, script, segment, split

Requisito de entrada¶

Oferece suporte a propriedades dinâmicas confidenciais¶

falso

Propriedades¶

Propriedade	Descrição
Diretório de módulos	Lista separada por vírgulas de caminhos para arquivos e/ou diretórios que contêm módulos exigidos pelo script.
Record Reader	O Record Reader a ser usado para analisar o FlowFile de entrada em registros
Record Writer	O Record Writer a ser usado para serializar registros depois de terem sido transformados
Corpo do script	Corpo do script a ser executado. Somente um dos itens de arquivo de script ou corpo de script pode ser usado
Mecanismo do script	O idioma a ser usado no script
Arquivo do script	Caminho para o arquivo de script a ser executado. Somente um dos itens de arquivo de script ou corpo de script pode ser usado

Restrições¶

Permissão necessária	Explicação
executar código	Fornece ao operador a capacidade de executar código arbitrário assumindo todas as permissões que o NiFi possui.

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
partition	A partição do FlowFile de saída. Se o script indicar que a partição tem um valor nulo, o atributo será definido como a cadeia de caracteres literal “<null partition>” (sem aspas). Caso contrário, o atributo é definido como a representação cadeia de caracteres de qualquer valor retornado pelo script.
mime.type	Define o atributo mime.type para o tipo MIME especificado pelo Record Writer
record.count	O número de registros no FlowFile.
record.error.message	Esse atributo fornece, em caso de falha, a mensagem de erro encontrada pelo leitor ou gravador.
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