FetchDistributedMapCache 2025.10.2.19¶
Pacote¶
org.apache.nifi | nifi-standard-nar
Descrição¶
Computes cache key(s) from FlowFile attributes, for each incoming FlowFile, and fetches the value(s) from the Distributed Map Cache associated with each key. If configured without a destination attribute, the incoming FlowFile “s content is replaced with the binary data received by the Distributed Map Cache. If there is no value stored under that key then the flow file will be routed to” not-found “. Note that the processor will always attempt to read the entire cached value into memory before placing it in it’s destination. This could be potentially problematic if the cached value is very large.
Requisito de entrada¶
REQUIRED
Oferece suporte a propriedades dinâmicas confidenciais¶
falso
Propriedades¶
Propriedade |
Descrição |
|---|---|
Identificador de entrada de cache |
Uma lista delimitada por vírgulas de atributos do FlowFile, ou os resultados de instruções de linguagem de expressão de atributo, que serão avaliados em relação ao FlowFile para determinar o(s) valor(es) usado(s) para identificar duplicatas; são esses valores que são armazenados em cache. NOTE: somente um único identificador de entrada de cache é permitido, a menos que Colocar valor do cache no atributo (Put Cache Value In Attribute) seja especificado. Só há suporte para pesquisas múltiplas de cache quando o destino é um conjunto de atributos (consulte a documentação de “Colocar valor do cache no atributo” para obter mais detalhes, inclusive a convenção de nomenclatura). |
Conjunto de caracteres |
O conjunto de caracteres no qual o valor armazenado em cache é codificado. Isso só será usado no roteamento para um atributo. |
Serviço de cache distribuído |
O Controller Service usado para obter os valores em cache. |
Comprimento máximo para colocar no atributo |
Se você rotear o valor do cache para um atributo do FlowFile (definindo a propriedade “Colocar valor do cache no atributo”), o número de caracteres colocados no valor do atributo será, no máximo, esse valor. Isso é importante porque os atributos são mantidos na memória e atributos grandes causarão rapidamente problemas de falta de memória. Se a saída for maior que esse valor, ela será truncada para caber. Se possível, considere diminuir o tamanho. |
Colocar valor do cache no atributo |
Se definido, o valor do cache recebido será colocado em um atributo do FlowFile em vez de no conteúdo do FlowFile. A chave de atributo a ser colocada é determinada pela avaliação do valor dessa propriedade. Se vários identificadores de entrada de cache forem selecionados, vários atributos serão gravados, usando o valor avaliado dessa propriedade, anexado por um ponto (.) e o nome do identificador de entrada de cache. |
Relações¶
Nome |
Descrição |
|---|---|
failure |
Se não for possível se comunicar com o cache ou se a entrada do cache for avaliada como em branco, o FlowFile será penalizado e encaminhado para essa relação |
not-found |
Se o identificador de entrada de cache do FlowFile não for encontrado no cache, ele será encaminhado para essa relação |
success |
Se a comunicação com o cache for bem-sucedida, ele será encaminhado para essa relação |
Grava atributos¶
Nome |
Descrição |
|---|---|
user-defined |
Se a propriedade “Colocar valor do cache no atributo” estiver definida, o que quer que esteja definido se tornará a chave do atributo e o valor será qualquer que seja a resposta do cache de mapa distribuído. Se vários identificadores de entrada de cache forem selecionados, vários atributos serão gravados, usando o valor avaliado dessa propriedade, anexado por um ponto (.) e o nome do identificador de entrada de cache. Por exemplo, se a propriedade Identificador de entrada de cache for definida como “id,name” e a propriedade definida pelo usuário for denominada “fetched”, serão gravados dois atributos, fetched.id e fetched.name, contendo seus respectivos valores. |