Tous les processeurs (par ordre alphabétique)

Cette rubrique fournit une liste de tous les processeurs Snowflake par ordre alphabétique. La liste comprend :

  • Le nom de chaque processeur

  • Un résumé de chaque processeur

A

Processeur

Description

Snowflake

AbortQueryJob

Abandonne une requête dans Salesforce à l’aide de la fonction Bulk API 2.

AttributesToCSV

Génère une représentation CSV des attributs du FlowFile d’entrée.

AttributesToJSON

Génère une représentation JSON des attributs du FlowFile d’entrée.

C

Processeur

Description

CalculateRecordStats

Compte le nombre d’enregistrements compris dans un ensemble d’enregistrements en dénombrant éventuellement les éléments par catégorie - les catégories étant définies par des propriétés définies par l’utilisateur.

Snowflake

CaptureChangeMySQL

Lit les événements CDC à partir d’une base de données MySQL.

Snowflake

CaptureChangePostgreSQL

Lit les événements CDC à partir d’une base de données PostgreSQL.

Snowflake

CaptureChangeSqlServer

Lit les événements CDC à partir d’une base de données SQL Server.

Snowflake

CaptureGoogleDriveChanges

Capture les modifications apportées à un Google Drive partagé et émet un FlowFile pour chaque modification survenue.

Snowflake

CaptureMicrosoft365GroupsChanges

Capture les changements survenant dans les groupes Microsoft365 et émet un FlowFile pour chaque changement qui se produit.

Snowflake

CaptureSharepointChanges

Capture les changements survenus dans une bibliothèque de documents Sharepoint et émet un FlowFile pour chacun d’entre eux.

Snowflake

CheckMetaAdsReportReadiness

Ce processeur vérifie si le rapport Meta Ads est prêt à être téléchargé.

Snowflake

ChunkRecordText

Découpe le texte en morceaux avec des options de division récursive par délimiteurs et par nombre maximal de caractères.

Snowflake

ChunkText

Découpe le texte en morceaux avec des options de division récursive par délimiteurs et par nombre maximal de caractères.

CompressContent

Compresse ou décompresse le contenu de FlowFiles à l’aide d’un algorithme de compression spécifié par l’utilisateur et met à jour le mime.

ConnectWebSocket

Joue le rôle de point de terminaison de client WebSocket pour interagir avec un serveur WebSocket distant.

ConsumeAMQP

Consomme les messages AMQP d’un courtier AMQP à l’aide de AMQP 0.

ConsumeAzureEventHub

Reçoit des messages de Microsoft Azure Event Hubs avec un mécanisme de points de contrôle garantissant un traitement cohérent des événements.

ConsumeBoxEnterpriseEvents

Consomme les événements d’entreprise des flux Box de type admin_logs_streaming.

ConsumeBoxEvents

Consomme tous les événements de Box.

ConsumeElasticsearch

Un processeur qui exécute de manière répétée une requête paginée sur un champ à l’aide d’une requête Range pour consommer de nouveaux documents à partir d’un index/d’une requête Elasticsearch.

ConsumeGCPubSub

Consomme les messages de l’abonnement configuré à Google Cloud PubSub.

ConsumeIMAP

Consomme les messages du serveur de messagerie en utilisant le protocole IMAP.

ConsumeJMS

Consomme un message JMS du type BytesMessage, TextMessage, ObjectMessage, MapMessage ou StreamMessage, transforme son contenu en FlowFile et le transmet à la relation « success ».

ConsumeKafka

Consomme les messages de l’API Apache Kafka Consumer.

Snowflake

ConsumeKafka

Consomme les messages de l’API Apache Kafka Consumer.

ConsumeKinesisStream

Lit les données du flux AWS Kinesis spécifié et génère un FlowFile pour chaque enregistrement traité (brut) ou un FlowFile pour un lot d’enregistrements traités si un Record Reader et un Record Writer sont configurés.

ConsumeMQTT

S’abonner à un sujet et recevoir des messages d’un broker MQTT

ConsumePOP3

Consomme les messages du serveur de messagerie en utilisant le protocole POP3.

ConsumeSlack

Récupère les messages d’un ou plusieurs canaux Slack configurés.

Snowflake

ConsumeSlackConversation

Récupère les messages des conversations Slack disponibles pour l’application.

Snowflake

ConsumeSlackHistory

Récupère l’historique des messages de tous les canaux Slack disponibles pour l’application.

Snowflake

ConsumeSnowflakeStream

Récupère les données d’un flux Snowflake et les écrit sur un FlowFile.

ConsumeTwitter

Diffuse des tweets à partir de l’API de streaming version 2 de Twitter.

ControlRate

Contrôle le débit auquel les données sont transférées aux processeurs suivants.

ConvertCharacterSet

Convertit le contenu d’un FlowFile d’un jeu de caractères à un autre

ConvertRecord

Convertit les enregistrements d’un format de données à un autre à l’aide des Controller Services Record Reader et Record Writer configurés.

Snowflake

ConvertToJournalSchema

Convertit le schéma de la base de données entrante en un schéma approprié pour une table Snowflake CDC Journal.

CopyAzureBlobStorage_v12

Copie un blob présent dans le stockage Azure Blob d’un compte/conteneur à un autre.

CopyS3Object

Copie un fichier d’un compartiment et d’une clé vers un autre dans AWS S3

CountText

Calcule différentes métriques sur le texte entrant.

Snowflake

CreateAmazonAdsReport

Processeur qui crée la configuration des rapports pour le connecteur Amazon Ads.

Snowflake

CreateAzureOpenAiEmbeddings

Utilise Azure OpenAI pour créer des intégrations pour le texte.

CreateBoxFileMetadataInstance

Crée une instance de métadonnées pour un fichier Box à l’aide d’un modèle spécifié avec des valeurs issues du contenu du FlowFile.

CreateBoxMetadataTemplate

Crée un modèle de métadonnées Box à l’aide des spécifications de champ provenant du contenu du FlowFile.

Snowflake

CreateCohereEmbeddings

Utilise Cohere pour créer des intégrations pour le texte.

Snowflake

CreateMetaAdsReport

Processeur qui crée la configuration des rapports pour le connecteur Meta Ads.

Snowflake

CreateOpenAiEmbeddings

Utilise OpenAI pour créer des intégrations pour le texte.

Snowflake

CreateSnowflakeEmbeddings

Créer des intégrations vectorielles à l’aide de fonctions Snowflake Cortex Large Language Model

Snowflake

CreateVertexAIEmbeddings

Utilise VertexAI pour créer des intégrations pour le texte.

CryptographicHashContent

Calcule une valeur de hachage cryptographique pour le contenu du FlowFile à l’aide de l’algorithme donné et l’écrit dans un attribut de sortie.

D

Processeur

Description

DebugFlow

Le processeur DebugFlow facilite les tests et le débogage du cadre FlowFile en permettant de déclencher explicitement diverses réponses suite à la réception d’un FlowFile ou d’un événement de temporisateur sans FlowFile si vous utilisez une planification basée sur un temporisateur ou sur cron.

DecryptContentAge

Déchiffre le contenu à l’aide de la spécification age-encryption.

DecryptContentPGP

Déchiffrer le contenu de messages OpenPGP.

DeduplicateRecord

Ce processeur dédouble les enregistrements individuels au sein d’un ensemble d’enregistrements.

DeleteAzureBlobStorage_v12

Supprime le blob spécifié d’Azure Blob Storage.

DeleteAzureDataLakeStorage

Supprime le fichier fourni d’Azure Data Lake Storage

DeleteBoxFileMetadataInstance

Supprime une instance de métadonnées d’un fichier Box à l’aide de la clé de modèle spécifiée

DeleteByQueryElasticsearch

Effectuer une suppression d’un index Elasticsearch à l’aide d’une requête.

Snowflake

DeleteDBFSResource

Supprimer des fichiers et répertoires DBFS.

DeleteDynamoDB

Supprime un document de DynamoDB en fonction d’une clé de hachage et d’intervalle.

DeleteFile

Supprime un fichier du système de fichiers.

DeleteGCSObject

Supprime des objets d’un compartiment Google Cloud.

DeleteGridFS

Supprime un fichier de GridFS à l’aide d’un nom de fichier ou d’une requête.

Snowflake

DeleteMilvus

Supprime des vecteurs de la base de données Milvus d’une collection par ID.

DeleteMongo

Exécute une requête de suppression sur une collection MongoDB.

Snowflake

DeletePinecone

Supprime les vecteurs d’un index Pinecone.

Snowflake

DeleteQueryJob

Supprime une tâche de requête dans Salesforce à l’aide de la fonction Bulk API 2.

DeleteS3Object

Supprime un fichier d’un compartiment Amazon S3.

DeleteSFTP

Supprime un fichier résidant sur un serveur SFTP.

DeleteSQS

Supprime un message d’une file d’attente Amazon Simple Queuing Service

Snowflake

DeleteUnityCatalogResource

Supprimez un fichier ou un répertoire du catalogue Unity.

Snowflake

DescribeDataShare

Décrivez les métadonnées de partage de données spécifiées dans Salesforce Data Cloud.

Snowflake

DescribeSFDCObject

Décrire les métadonnées de l’objet spécifié dans Salesforce.

DetectDuplicate

Met en cache une valeur, calculée à partir des attributs de FlowFile, pour chaque FlowFile entrant et détermine si la valeur mise en cache a déjà été vue.

DistributeLoad

Distribue les FlowFiles aux transformateurs en aval sur la base d’une stratégie de distribution.

DuplicateFlowFile

Destiné aux tests de charge, ce processeur créera le nombre configuré de copies de chaque FlowFile entrant.

E

Processeur

Description

EncodeContent

Encodez ou décodez le contenu d’un FlowFile à l’aide des schémas d’encodage Base64, Base32 ou hexadécimal

EncryptContentAge

Chiffre le contenu à l’aide de la spécification age-encryption.

EncryptContentPGP

Chiffrer le contenu à l’aide de OpenPGP.

EnforceOrder

Renforce l’ordre attendu des FlowFiles qui appartiennent au même groupe de données au sein d’un même nœud.

Snowflake

EnrichAttributes

Recherche une valeur à l’aide du service de recherche configuré et ajoute les résultats au FlowFile sous la forme d’un ou plusieurs attributs.

Snowflake

EnrichCdcStream

Enrichit les FlowFiles entrants qui proviennent de CaptureChangePostgreSQL, etc.

EvaluateJsonPath

Évalue une ou plusieurs expressions de JsonPath par rapport au contenu du FlowFile.

Snowflake

EvaluateRagAnswerCorrectness

Évalue l’exactitude des réponses générées dans un contexte de génération assistée par la recherche (RAG) en calculant des mesures telles que le score F1, la similarité cosinusoïdale et l’exactitude de la réponse.

Snowflake

EvaluateRagFaithfulness

Évalue la fidélité des réponses générées dans un système de génération augmentée de récupération (RAG) en analysant les réponses à l’aide d’un LLM (e.

Snowflake

EvaluateRagRetrieval

Calcule les mesures de récupération (Precision@N, Recall@N, FScore@N, MAP@N, MRR) pour un système RAG en utilisant un LLM comme juge.

EvaluateXPath

Évalue un ou plusieurs XPaths par rapport au contenu d’un FlowFile.

EvaluateXQuery

Évalue un ou plusieurs XQueries par rapport au contenu d’un FlowFile.

ExecuteGroovyScript

Processeur expérimental de scripts Groovy étendus.

ExecuteProcess

Exécute une commande du système d’exploitation spécifiée par l’utilisateur et écrit la sortie de cette commande sur un FlowFile.

ExecuteScript

Expérimental - Exécute un script à partir d’un fichier de flux et d’une session de traitement.

ExecuteSQL

Exécute la requête SELECT fournie à SQL.

ExecuteSQLRecord

Exécute la requête SELECT fournie à SQL.

Snowflake

ExecuteSQLStatement

Exécute une instruction SQL DDL ou DML sur une base de données.

ExecuteStreamCommand

Le processeur ExecuteStreamCommand offre un moyen souple d’intégrer des commandes et des scripts externes dans les flux de données de NiFi.

ExtractAvroMetadata

Extrait les métadonnées de l’en-tête d’un fichier de données Avro.

ExtractEmailAttachments

Extrayez les pièces jointes d’un fichier e-mail au format mime, en les divisant en fichiers de flux individuels.

ExtractEmailHeaders

En utilisant le contenu du fichier de flux comme source de données, extrayez l’en-tête d’un fichier de courrier électronique conforme à RFC en ajoutant les attributs pertinents au fichier de flux.

ExtractGrok

Évalue une ou plusieurs expressions Grok par rapport au contenu d’un FlowFile, en ajoutant les résultats en tant qu’attributs ou en remplaçant le contenu du FlowFile par une notation JSON du contenu correspondant

ExtractRecordSchema

Extrait le schéma d’enregistrement du FlowFile à l’aide du Record Reader fourni et l’écrit dans l’attribut “avro.

Snowflake

ExtractSchemaColumns

Extrait les colonnes du schéma d’enregistrement du FlowFile à l’aide du Record Reader fourni et les écrit dans l’attribut ‘schema.

ExtractStructuredBoxFileMetadata

Extrait les métadonnées d’un fichier Box à l’aide de Box AI.

ExtractText

Évalue une ou plusieurs expressions régulières par rapport au contenu d’un FlowFile.

F

Processeur

Description

FetchAzureBlobStorage_v12

Récupère le blob spécifié dans Azure Blob Storage et écrit son contenu dans le contenu du FlowFile.

FetchAzureDataLakeStorage

Récupérer le fichier spécifié à partir du stockage Azure Data Lake

FetchBoxFile

Récupère les fichiers d’un dossier Box.

FetchBoxFileInfo

Récupère les métadonnées des fichiers dans Box et les ajoute aux attributs du FlowFile.

FetchBoxFileMetadataInstance

Récupère une instance de métadonnées spécifique associée à un fichier Box à l’aide d’une clé de modèle et d’un champ d’application.

FetchBoxFileRepresentation

Extrait la représentation d’un fichier Box à l’aide d’un indice de représentation et l’écrit dans le contenu du FlowFile.

FetchDistributedMapCache

Calcule la (les) clé(s) de cache à partir des attributs du FlowFile, pour chaque FlowFile entrant, et récupère(nt) la (les) valeur(s) du mappage distribué associée(s) à chaque clé.

FetchDropbox

Récupère des fichiers dans Dropbox.

FetchFile

Lit le contenu d’un fichier sur le disque et le transfère en flux dans le contenu d’un FlowFile entrant.

FetchFTP

Récupère le contenu d’un fichier sur un serveur FTP distant et remplace le contenu d’un FlowFile entrant par le contenu du fichier distant.

FetchGCSObject

Récupère un fichier à partir d’un compartiment de Google Cloud.

FetchGoogleDrive

Récupère des fichiers à partir d’un dossier Google Drive.

Snowflake

FetchGoogleDriveFileComments

Récupère les commentaires et leurs réponses dans un fichier Google Drive.

Snowflake

FetchGoogleDriveMetadata

Récupère les métadonnées des fichiers de Google Drive.

FetchGridFS

Récupère un ou plusieurs fichiers d’un compartiment GridFS par nom de fichier ou par requête définie par l’utilisateur.

Snowflake

FetchJiraIssues

Récupère les problèmes dans Jira Cloud à l’aide de l’API REST v3 avec des options de recherche configurables.

Snowflake

FetchMicrosoftDataverseTable

Récupérer des enregistrements dans les tables Microsoft Dataverse

FetchS3Object

Récupère le contenu d’un objet S3 et l’écrit dans le contenu d’un FlowFile

FetchSFTP

Récupère le contenu d’un fichier sur un serveur SFTP distant et remplace le contenu d’un FlowFile entrant par le contenu du fichier distant.

Snowflake

FetchSharepointFile

Récupère le contenu d’un fichier à partir d’un lecteur Sharepoint, en téléchargeant éventuellement une version PDF ou HTML du fichier, le cas échéant.

Snowflake

FetchSharepointMetadata

Pour chaque lecteur, l’élément récupère ses métadonnées et ses autorisations et les écrit sous forme d’attributs FlowFile.

Snowflake

FetchSlackConversationInfo

Récupère les infos des conversations Slack et les emails des membres

Snowflake

FetchSlackFile

Télécharge un fichier partagé sur Slack.

Snowflake

FetchSlackMessage

Récupère les données relatives à un seul message Slack

FetchSmb

Récupère des fichiers à partir d’un partage SMB.

Snowflake

FetchSnowflakeTableProperties

Lit les propriétés d’une table et les stocke en tant qu’attributs du FlowFile.

Snowflake

FetchSourceTableSchema

Récupère le schéma de la table (i.

Snowflake

FetchTableSnapshot

Extrait un instantané d’une table d’une base de données.

FilterAttribute

Filtre les attributs d’un FlowFile en conservant les attributs spécifiés et en supprimant le reste ou en supprimant les attributs spécifiés et en conservant le reste.

Snowflake

FindSharepointDriveItem

Trouve un élément de Drive Sharepoint par son ID de lecteur et le chemin de l’élément.

FlattenJson

Donne à l’utilisateur la possibilité de prendre une documentation JSON imbriquée et de l’aplatir en un simple document de paires clé/valeur.

ForkEnrichment

Utilisé conjointement avec le processeur JoinEnrichment, ce processeur est chargé d’ajouter les attributs nécessaires à l’accomplissement de la fonction du processeur JoinEnrichment.

ForkRecord

Ce processeur permet à l’utilisateur de diviser un enregistrement en plusieurs enregistrements.

G

Processeur

Description

Snowflake

GenerateAnswersFromContext

Génère des réponses synthétiques pour chaque question présente dans les enregistrements entrants à l’aide d’un grand modèle de langage (LLM).

Snowflake

GenerateAnswersFromGroundTruth

Génère des réponses synthétiques pour chaque question des enregistrements entrants à l’aide d’un LLM.

GenerateFlowFile

Ce processeur crée des FlowFiles avec des données aléatoires ou un contenu personnalisé.

Snowflake

GenerateJSON

Produit un lot d’objets JSON avec des valeurs de champ aléatoires basées sur un schéma JSON configurable.

GenerateRecord

Ce processeur crée des FlowFiles avec des enregistrements dont les valeurs des champs spécifiés sont aléatoires.

GenerateTableFetch

Génère des requêtes SQL SELECT qui récupèrent des « pages » de lignes d’une table.

GeoEnrichIP

Recherche les informations de géolocalisation pour une adresse IP et ajoute les informations de géolocalisation aux attributs FlowFile.

GeoEnrichIPRecord

Recherche les informations de géolocalisation pour une adresse IP et ajoute les informations de géolocalisation aux attributs FlowFile.

Snowflake

GetAmazonAdsReport

Le processeur télécharge le rapport des publicités Amazon s’il est prêt.

GetAwsPollyJobStatus

Récupère le statut actuel d’une tâche AWS Polly.

GetAwsTextractJobStatus

Récupère le statut actuel d’un travail AWS Textract.

GetAwsTranscribeJobStatus

Récupère le statut actuel d’une tâche AWS Transcribe.

GetAwsTranslateJobStatus

Récupère le statut actuel d’une tâche AWS Translate.

GetAzureEventHub

Reçoit des messages provenant de Microsoft Azure Event Hubs sans suivi fiable des points de contrôle.

GetAzureQueueStorage_v12

Récupère les messages à partir d’un stockage Azure Queue Storage.

GetBoxFileCollaborators

Récupère tous les collaborateurs d’un fichier Box et ajoute les informations de collaboration aux attributs de FlowFile.

GetBoxGroupMembers

Récupère les membres d’un groupe Box et écrit leurs détails dans les attributs FlowFile.

Snowflake

GetDataShareCredentials

Décrivez les métadonnées de partage de données spécifiées dans Salesforce Data Cloud.

Snowflake

GetDataShareTables

Décrivez les métadonnées de partage de données spécifiées dans Salesforce Data Cloud.

Snowflake

GetDBFSFile

Lire un fichier DBFS.

GetDynamoDB

Récupère un document à partir de DynamoDB sur la base d’un hachage et d’une clé d’intervalle.

GetElasticsearch

Processeur d’extraction Elasticsearch qui utilise les bibliothèques client officielles Elastic REST pour extraire un document unique d’Elasticsearch par _id.

GetFile

Crée FlowFiles à partir des fichiers d’un répertoire.

GetFileResource

Ce processeur crée des FlowFiles avec le contenu de la ressource fichier configurée.

GetFTP

Récupère les fichiers d’un serveur FTP et crée les FlowFiles à partir de ces fichiers

GetGcpVisionAnnotateFilesOperationStatus

Récupère le statut actuel d’une opération Google Vision.

GetGcpVisionAnnotateImagesOperationStatus

Récupère le statut actuel d’une opération Google Vision.

Snowflake

GetGoogleAdsReport

Un processeur qui peut interagir avec Google Ads Reporting API.

Snowflake

GetGoogleGroupMembers

Récupère les membres d’un ou de plusieurs groupes Google, spécifiés sous la forme d’une liste d’IDs de groupe séparés par des virgules et donnés comme attribut FlowFile.

Snowflake

GetGoogleSheets

Processeur chargé d’extraire les données de Google Sheets.

GetHubSpot

Récupère les données JSON à partir d’une application privée HubSpot.

Snowflake

GetHubSpotObject

Obtenir un objet HubSpot et ses associations par ID ou par valeur unique.

Snowflake

GetLinkedInAdsReport

Le processeur télécharge des mesures à partir des APIs LinkedIn Reporting.

Snowflake

GetMicrosoft365GroupMembers

Récupère les membres du groupe Microsoft365 et émet un FlowFile pour chaque changement survenu.

GetMongo

Crée des FlowFiles à partir de documents de MongoDB chargés par une requête spécifiée par l’utilisateur.

GetMongoRecord

Une version de GetMongo basée sur les enregistrements qui utilise les Record Writers pour écrire le jeu de résultats de MongoDB.

Snowflake

GetQueryJobResult

Obtient les résultats d’une requête dans Salesforce à l’aide de la fonction Bulk API 2.

Snowflake

GetQueryJobStatus

Obtient le statut d’une requête dans Salesforce à l’aide de la fonction Bulk API 2.

GetS3ObjectMetadata

Vérifie l’existence d’un objet dans S3 et récupère ses métadonnées sans tenter de le télécharger.

GetS3ObjectTags

Vérifie l’existence d’un objet dans S3 et récupère ses balises sans tenter de le télécharger.

GetSFTP

Récupère les fichiers d’un serveur SFTP et crée les FlowFiles à partir de ces fichiers

Snowflake

GetSharepointSiteGroupMembers

Récupère tous les membres d’un groupe de sites SharePoint.

GetShopify

Récupère les objets d’une boutique Shopify personnalisée.

GetSmbFile

Lit un fichier à partir d’un emplacement du réseau samba sur des FlowFiles.

GetSplunk

Récupère les données de Splunk Enterprise.

GetSQS

Récupère les messages d’une file d’attente Amazon Simple Queuing Service

Snowflake

GetUnityCatalogFile

Lit un fichier Unity Catalog jusqu’à 5 GiB.

Snowflake

GetUnityCatalogFileMetadata

Vérifie les métadonnées du fichier Unity Catalog.

GetWorkdayReport

Un processeur qui peut interagir avec un rapport Workday configurable.

GetZendesk

Récupère de manière incrémentale les données de Zendesk API.

H

Processeur

Description

HandleHttpRequest

Démarre un serveur HTTP et écoute les requêtes HTTP.

HandleHttpResponse

Envoie une réponse HTTP au demandeur qui a généré un FlowFile.

I

Processeur

Description

IdentifyMimeType

Tente d’identifier le type MIME utilisé pour un FlowFile.

InvokeHTTP

Un processeur client HTTP qui peut interagir avec un point de terminaison HTTP configurable.

InvokeScriptedProcessor

Expérimental - Invoque un moteur de script pour un processeur défini dans le script donné.

ISPEnrichIP

Recherche les informations de ISP pour une adresse IP et ajoute les informations aux attributs de FlowFile.

J

Processeur

Description

JoinEnrichment

Réunit des enregistrements provenant de deux FlowFiles différents, dont l’un, FlowFile original, contient des enregistrements arbitraires et l’autre, FlowFile d’enrichissement, contient des données supplémentaires à utiliser pour enrichir le premier.

JoltTransformJSON

Applique une liste de spécifications Jolt au contenu de FlowFile JSON, ou à un attribut spécifié de FlowFile JSON.

JoltTransformRecord

Applique une spécification JOLT à chaque enregistrement de la charge utile FlowFile.

JSLTTransformJSON

Applique une transformation JSLT à la charge utile FlowFile JSON.

JsonQueryElasticsearch

Un processeur qui permet à l’utilisateur d’exécuter une requête (avec des agrégations) écrite avec Elasticsearch JSON DSL.

L

Processeur

Description

Snowflake

ListArchivedHubSpotData

Répertorie les données archivées sur HubSpot pour le type d’objet choisi et génère un FlowFile par objet répertorié avec les métadonnées correspondantes en tant qu’attributs FlowFile.

ListAzureBlobStorage_v12

Établit la liste des blobs dans un conteneur de stockage Azure Blob.

ListAzureDataLakeStorage

Liste le répertoire dans un système de fichiers Azure Data Lake Storage Gen 2

ListBoxFile

Liste les fichiers d’un dossier Box.

ListBoxFileInfo

Récupère les métadonnées de chaque fichier d’un dossier Box.

ListBoxFileMetadataInstances

Récupère toutes les instances de métadonnées associées à un fichier Box.

ListBoxFileMetadataTemplates

Récupère tous les modèles de métadonnées associés à un fichier Box.

ListDatabaseTables

Génère un ensemble de FlowFiles, chacun contenant des attributs correspondant aux métadonnées d’une table à partir d’une connexion à la base de données.

Snowflake

ListDBFSDirectory

Liste les noms de fichiers dans un répertoire DBFS et génère un nouveau FlowFile en sortie avec le nom du fichier.

ListDropbox

Récupère un listing de fichiers à partir de Dropbox (les raccourcis sont ignorés).

ListenFTP

Démarre un serveur FTP qui écoute sur le port spécifié et transforme les fichiers entrants en FlowFiles.

ListenHTTP

Démarre un serveur HTTP et écoute sur un chemin de base donné pour transformer les requêtes entrantes en FlowFiles.

ListenOTLP

Collecte les messages OpenTelemetry sur HTTP ou gRPC.

ListenSlack

Récupère les messages en temps réel ou les commandes Slack d’une ou plusieurs conversations Slack.

ListenSyslog

Écoute des messages Syslog envoyés à un port donné via TCP ou UDP.

ListenTCP

Écoute les connexions TCP entrantes et lit les données de chaque connexion en utilisant un séparateur de ligne comme délimiteur de message.

ListenUDP

Écoute des paquets de datagrammes sur un port donné.

ListenUDPRecord

Écoute les paquets de datagrammes sur un port donné et lit le contenu de chaque datagramme à l’aide du Record Reader configuré.

ListenWebSocket

Joue le rôle de point de terminaison du serveur WebSocket pour accepter les connexions client.

ListFile

Récupère une liste de fichiers dans le répertoire d’entrée.

ListFTP

Effectue une liste des fichiers résidant sur un serveur FTP.

ListGCSBucket

Récupère une liste d’objets dans un compartiment GCS.

ListGoogleDrive

Effectue une liste des fichiers concrets (les raccourcis sont ignorés) dans un dossier Google Drive.

Snowflake

ListGoogleDriveFileInfo

Établit la liste de tous les fichiers et dossiers d’un Google Drive spécifié.

Snowflake

ListGoogleGroups

Répertorie tous les groupes d’un domaine donné dans Google Workspace.

Snowflake

ListHubSpotObjects

Extrait les données de HubSpot pour les types d’objets spécifiés et génère un FlowFile par objet répertorié avec les métadonnées correspondantes en tant qu’attributs de FlowFile.

Snowflake

ListMicrosoftDataverseTables

Tables de liste des environnements Microsoft Dataverse

ListS3

Récupère une liste d’objets à partir d’un compartiment S3.

Snowflake

ListSFDCDataShares

Dresse la liste des partages de données disponibles dans l’organisation et accessibles à l’utilisateur identifié.

Snowflake

ListSFDCObjects

Liste des objets disponibles dans l’organisation et accessibles à l’utilisateur identifié.

ListSFTP

Effectue une liste des fichiers résidant sur un serveur SFTP.

Snowflake

ListSharepointDrives

Émet un FlowFile pour chaque lecteur présent dans le site Sharepoint spécifié.

Snowflake

ListSharepointSiteGroups

Liste tous les groupes de sites SharePoint disponibles sur un site SharePoint spécifié.

ListSmb

Liste des fichiers concrets partagés via le protocole SMB.

Snowflake

ListTableNames

Récupère tous les noms de table source et les met en correspondance avec l’une des configurations possibles :- regexp expression e.

Snowflake

ListUnityCatalogDirectory

Répertorie les noms de fichiers dans un répertoire du catalogue Unity et génère une nouvelle page FlowFile avec le nom du fichier en sortie.

LogAttribute

Émet les attributs de FlowFile au niveau de journalisation spécifié

LogMessage

Émet un message de journalisation au niveau de journalisation spécifié

LookupAttribute

Recherche d’attributs à partir d’un service de consultation

LookupRecord

Extrait un ou plusieurs champs d’un enregistrement et recherche une valeur pour ces champs dans LookupService.

M

Processeur

Description

MergeContent

Fusionne un groupe de FlowFiles sur la base d’une stratégie définie par l’utilisateur et les regroupe en un seul FlowFile.

MergeRecord

Ce processeur fusionne plusieurs enregistrements FlowFiles en un seul FlowFile qui contient tous les enregistrements du FlowFiles en entrée.

Snowflake

MergeSnowflakeJournalTable

Déclenche une opération de fusion sur les modifications de la table du journal vers une table de destination dans Snowflake.

ModifyBytes

Rejette une plage d’octets au début et à la fin ou tout le contenu d’un fichier binaire.

ModifyCompression

Modifie l’algorithme de compression utilisé pour compresser le contenu d’un FlowFile en décompressant le contenu des FlowFiles via un algorithme de compression spécifié par l’utilisateur et en recompressant le contenu à l’aide des propriétés du format de compression spécifiées.

MonitorActivity

Surveille l’activité du flux et envoie un indicateur lorsque le flux n’a pas reçu de données pendant une période donnée, puis à nouveau lorsque l’activité du flux est rétablie

MoveAzureDataLakeStorage

Déplace le contenu au sein d’un Azure Data Lake Storage Gen 2.

N

Processeur

Description

Notify

Met en cache un identificateur de signal de version dans le cache distribué, éventuellement avec les attributs du FlowFile.

O

Processeur

Description

Snowflake

OpenAiTranscribeAudio

Procède à la transcription du son en texte anglais.

P

Processeur

Description

PackageFlowFile

Ce processeur regroupera les attributs et le contenu de FlowFile dans unFlowFile en sortie qui peut être exporté de NiFi et réimporté dans NiFi, en préservant les attributs et le contenu d’origine.

PaginatedJsonQueryElasticsearch

Un processeur qui permet à l’utilisateur d’exécuter une requête paginée (avec agrégations) écrite avec Elasticsearch JSON DSL.

ParseEvtx

Analyse le contenu d’un fichier du journal des événements Windows (evtx) et écrit l’adresse XML qui en résulte dans le FlowFile

Snowflake

ParseExcelCellReference

Processeur responsable de l’analyse des formules de référence des cellules Excel.

ParseSyslog

Tente d’analyser le contenu d’un message Syslog conformément aux formats RFC5424 et RFC3164 et ajoute des attributs au FlowFile pour chacune des parties du message Syslog.

ParseSyslog5424

Tente d’analyser le contenu d’un message Syslog conforme au format RFC5424 et ajoute des attributs au FlowFile pour chacune des parties du message Syslog, y compris les données structurées.

PartitionRecord

Fractionne, ou partitionne, les données orientées enregistrement en fonction des champs configurés dans les données.

Snowflake

PerformSnowflakeCortexOCR

Effectue la reconnaissance optique des caractères (OCR) sur les documents PDF en utilisant les fonctions ML du Snowflake Cortex.

Snowflake

PickTablesForReplication

Accepte une liste de noms de tables entièrement qualifiés et détermine si une table : - est nouvelle (n’est pas répliquée, mais a été ajoutée dans la source) - est existante (est répliquée et existe dans la source) - est périmée (est répliquée mais n’existe plus dans la source) La configuration est transmise en tant qu’attribut de FlowFile.

Snowflake

PromptAnthropicAI

Envoie une invite à Anthropic, en écrivant la réponse sous forme d’attribut FlowFile ou dans le contenu du FlowFile entrant.

Snowflake

PromptAzureOpenAI

Envoie une invite au service OpenAI d’Azure, en écrivant la réponse soit sous forme d’attribut FlowFile, soit dans le contenu du FlowFile entrant.

Snowflake

PromptLLM

Ce processeur envoie une invite définie par l’utilisateur à un Large Language Model (LLM) pour qu’il y réponde.

Snowflake

PromptOpenAI

Envoie une invite à OpenAI, en écrivant la réponse sous forme d’attribut de FlowFile ou dans le contenu du FlowFile entrant.

Snowflake

PromptSnowflakeCortex

Envoie une demande à Snowflake Cortex, en écrivant la réponse sous la forme d’un attribut FlowFile ou dans le contenu du FlowFile entrant.

Snowflake

PromptVertexAI

Envoie une invite à VertexAI, en écrivant la réponse sous forme d’attribut de FlowFile ou dans le contenu du FlowFile entrant.

PublishAMQP

Crée un message AMQP à partir du contenu d’un FlowFile et envoie le message à un échange AMQP.

PublishGCPubSub

Publie le contenu du FlowFile entrant dans la rubrique configurée de Google Cloud PubSub.

PublishJMS

Crée un message JMS à partir du contenu d’un FlowFile et l’envoie à une destination JMS (file d’attente ou sujet) en tant que BytesMessage ou TextMessage JMS.

PublishKafka

Envoie le contenu d’un FlowFile sous forme de message ou d’enregistrements individuels à Apache Kafka à l’aide de Kafka Producer API.

Snowflake

PublishKafka

Envoie le contenu d’un FlowFile sous forme de message ou d’enregistrements individuels à Apache Kafka à l’aide de Kafka Producer API.

PublishMQTT

Publie un message sur un sujet MQTT

PublishSlack

Publie un message sur le canal Slack spécifié.

PutAzureBlobStorage_v12

Place le contenu dans un blob sur Azure Blob Storage.

PutAzureCosmosDBRecord

Ce processeur est un processeur d’enregistrement pour l’insertion de données dans Cosmos DB avec Core SQL API.

PutAzureDataExplorer

Agit comme un puits Azure Data Explorer qui envoie des FlowFiles au point de terminaison fourni.

PutAzureDataLakeStorage

Écrit le contenu d’un FlowFile en tant que fichier sur Azure Data Lake Storage Gen 2

PutAzureEventHub

Envoie le contenu de FlowFile sur Azure Event Hubs

PutAzureQueueStorage_v12

Écrit le contenu des FlowFiles entrants dans le stockage Azure Queue Sorage configuré.

PutBigQuery

Écrit le contenu d’un FlowFile dans une table Google BigQuery.

PutBoxFile

Place le contenu dans un dossier Box.

PutCloudWatchMetric

Publie les métriques sur Amazon CloudWatch.

PutDatabaseRecord

Le processeur PutDatabaseRecord utilise un RecordReader spécifié pour utiliser en entrée des enregistrements (éventuellement multiples) à partir d’un FlowFile entrant.

Snowflake

PutDatabricksSQL

Soumet une exécution SQL à l’aide de Databricks REST API puis écrit la réponse JSON dans le contenu du FlowFile.

Snowflake

PutDBFSFile

Rédige le contenu de FlowFile sur DBFS.

PutDistributedMapCache

Récupère le contenu d’un FlowFile et le place dans un cache de carte distribué, en utilisant une clé de cache calculée à partir des attributs de FlowFile.

PutDropbox

Place le contenu dans un dossier Dropbox.

PutDynamoDB

Place un document à partir de DynamoDB sur la base d’un hachage et d’une clé d’intervalle.

PutDynamoDBRecord

Insère des éléments dans DynamoDB sur la base de données orientées enregistrement.

PutElasticsearchJson

Un processeur de mise en place d’Elasticsearch qui utilise les bibliothèques client officielles d’Elastic REST.

PutElasticsearchRecord

Un processeur de mise en place d’Elasticsearch tenant compte des enregistrements et utilisant les bibliothèques client officielles d’Elastic REST.

PutEmail

Envoi d’un courrier électronique aux destinataires configurés pour chaque FlowFile entrant

PutFile

Écrit le contenu d’un FlowFile dans le système de fichiers local

PutFTP

Envoie des FlowFiles à un serveur FTP

PutGCSObject

Écrit le contenu d’un FlowFile en tant qu’objet dans un Google Cloud Storage.

PutGoogleDrive

Rédige le contenu d’un FlowFile sous forme de fichier dans Google Drive.

PutGridFS

Écrit un fichier dans un compartiment GridFS.

Snowflake

PutHubSpot

Insertion d’un objet HubSpot.

Snowflake

PutIcebergTable

Stocke les enregistrements dans Iceberg à l’aide d’un catalogue configurable pour la gestion des espaces de noms et des tables.

PutKinesisFirehose

Envoie le contenu vers un Amazon Kinesis Firehose spécifié.

PutKinesisStream

Envoie le contenu à un Amazon Kinesis spécifié.

PutLambda

Envoie le contenu à une fonction Amazon Lambda spécifiée.

PutMongo

Écrit le contenu d’un FlowFile sur MongoDB

PutMongoBulkOperations

Écrit le contenu d’un FlowFile sur MongoDB en tant que bulk-update

PutMongoRecord

Ce processeur est un processeur d’enregistrement pour l’insertion/la réinsertion de données dans MongoDB.

PutRecord

Le processeur PutRecord utilise un RecordReader spécifié pour retourner des enregistrements (éventuellement multiples) à partir d’un FlowFile entrant, et les envoie vers une destination spécifiée par un service de destination (i.

PutRedisHashRecord

Place les données des champs de l’enregistrement dans Redis en utilisant une valeur de hachage spécifiée, qui est déterminée par un RecordPath vers un champ contenant la valeur de hachage.

PutS3Object

Écrit le contenu d’un FlowFile en tant qu’objet S3 dans un compartiment Amazon S3 Bucket.

PutSalesforceObject

Crée de nouveaux enregistrements pour l’objet Salesforce sObject spécifié.

PutSFTP

Envoie des FlowFiles à un serveur SFTP

PutSmbFile

Écrit le contenu d’un FlowFile à un emplacement du réseau samba.

Snowflake

PutSnowflakeInternalStageFile

Place les fichiers dans une zone de préparation interne de Snowflake.

Snowflake

PutSnowpipeStreaming

Diffuse les enregistrements dans une table Snowflake.

PutSNS

Envoie le contenu d’un FlowFile sous forme de notification à Amazon Simple Notification Service

PutSplunk

Envoie les journaux à Splunk Enterprise via TCP, TCP + TLS/SSL, ou UDP.

PutSplunkHTTP

Envoie le contenu du FlowFile au serveur Splunk spécifié via HTTP ou HTTPS.

PutSQL

Exécute une commande SQL UPDATE ou INSERT.

PutSQS

Publie un message dans une file d’attente d’Amazon Simple Queuing Service

PutSyslog

Envoie des messages Syslog à un hôte et à un port donnés via TCP ou UDP.

PutTCP

Envoi de FlowFiles ou d’enregistrements sérialisés sur TCP vers une destination configurable avec prise en charge optionnelle de TLS

PutUDP

Le processeur PutUDP reçoit un FlowFile et regroupe le contenu FlowFile en un seul paquet de datagrammes UDP qui est ensuite transmis au serveur UDP configuré.

Snowflake

PutUnityCatalogFile

Rédige le contenu de FlowFile avec une taille maximale de 5 GiB pour Unity Catalog.

Snowflake

PutVectaraDocument

Génère et télécharge une documentation JSON vers le point de terminaison de Vectara.

Snowflake

PutVectaraFile

Télécharge un contenu FlowFile sur l’index du point de terminaison de Vectara.

PutWebSocket

Envoi de messages à un point de terminaison distant WebSocket à l’aide d’une session WebSocket établie par ListenWebSocket ou ConnectWebSocket.

PutZendeskTicket

Crée des tickets Zendesk à l’aide de Zendesk API.

Q

Processeur

Description

QueryAzureDataExplorer

Interroge Azure Data Explorer et diffuse les résultats JSON vers les FlowFiles en sortie

QueryDatabaseTable

Génère une requête SQL select, ou utilise une instruction fournie et l’exécute pour récupérer toutes les lignes dont les valeurs dans la (les) colonne(s) Valeur maximale spécifiée(s) sont plus grandes que les maxima précédemment observées.

QueryDatabaseTableRecord

Génère une requête SQL select, ou utilise une instruction fournie et l’exécute pour récupérer toutes les lignes dont les valeurs dans la (les) colonne(s) Valeur maximale spécifiée(s) sont plus grandes que les maxima précédemment observées.

Snowflake

QueryMilvus

Effectue la requête d’une collection donnée dans une base de données Milvus à l’aide de vecteurs.

Snowflake

QueryPinecone

Interroge Pinecone sur les vecteurs similaires au vecteur d’entrée, ou récupère un vecteur par ID.

QueryRecord

Évalue une ou plusieurs requêtes SQL par rapport au contenu d’un FlowFile.

QuerySalesforceObject

Récupère les enregistrements d’un objet Salesforce sObject.

QuerySplunkIndexingStatus

Interroge le serveur Splunk afin d’obtenir le statut de l’accusé de réception de l’indexation.

R

Processeur

Description

RemoveRecordField

Modifie le contenu d’un FlowFile qui contient des données orientées enregistrement (i.

RenameRecordField

Renomme un ou plusieurs champs dans chaque enregistrement d’un FlowFile.

ReplaceText

Met à jour le contenu d’un FlowFile en recherchant une certaine valeur textuelle dans le contenu du FlowFile (par le biais d’une expression régulière/regex ou d’une valeur littérale) et en remplaçant la section du contenu correspondqnt par une autre valeur.

ReplaceTextWithMapping

Met à jour le contenu d’un FlowFile en évaluant une expression régulière et en remplaçant la section du contenu qui correspond à l’expression régulière par une autre valeur fournie dans un fichier de mappage.

RetryFlowFile

Les FlowFiles transmis à ce processeur ont une valeur « Retry Attribute » vérifiée par rapport à une valeur « « Maximum Retries » configurée.

RouteOnAttribute

Route lesattribut FlowFiles en fonction de leurs attributs à l’aide de Attribute Expression Language

RouteOnContent

Applique des expressions régulières au contenu d’un FlowFile et route une copie du FlowFile vers chaque destination avec une expression régulière correspondante.

RouteText

Route des données textuelles sur la base d’un ensemble de règles définies par l’utilisateur.

Snowflake

RunDatabricksJob

Déclenche l’exécution d’un travail Databricks prédéfini avec des paramètres personnalisés.

RunMongoAggregation

Un processeur qui exécute une requête d’agrégation chaque fois qu’il reçoit un FlowFile.

S

Processeur

Description

SampleRecord

Échantillonne les enregistrements d’un FlowFile sur la base d’une stratégie d’échantillonnage spécifiée (telle que l’échantillonnage de réservoir).

ScanAttribute

Analyse les attributs spécifiés de FlowFiles, en vérifiant si l’une de leurs valeurs est présente dans le dictionnaire de termes spécifié

ScanContent

Recherche dans le contenu de FlowFiles les termes qui se trouvent dans un dictionnaire fourni par l’utilisateur.

ScriptedFilterRecord

Ce processeur offre la possibilité de filtrer les enregistrements à partir de FlowFiles à l’aide du script fourni par l’utilisateur.

ScriptedPartitionRecord

Reçoit des données orientées enregistrement (i.

ScriptedTransformRecord

Fournit la possibilité d’évaluer un script simple pour chaque enregistrement d’un FlowFile entrant.

ScriptedValidateRecord

Ce processeur offre la possibilité de valider les enregistrements dans les FlowFiles à l’aide du script fourni par l’utilisateur.

SearchElasticsearch

Un processeur qui permet à l’utilisateur d’exécuter de manière répétée une requête paginée (avec agrégations) écrite avec Elasticsearch JSON DSL.

SegmentContent

Segmente un FlowFile en plusieurs segments plus petits dans la limite des octets.

SignContentPGP

Signe le contenu à l’aide des clés privées de OpenPGP

Snowflake

SnowflakeDetectDuplicate

Vérifie si le hachage d’un FlowFile(fourni comme attribut FlowFile) se trouve déjà dans une table Snowflake, et route le FlowFile vers « duplicate » s’il est trouvé, « distinct » s’il n’est pas trouvé, ou « failure » en cas d’erreur.

SplitAvro

Divise un fichier de données Avro codé en binaire en plusieurs fichiers plus petits en fonction de la taille de sortie configurée.

SplitContent

Fractionne les FlowFiles entrants en fonction d’une séquence d’octets spécifiée

SplitExcel

Ce processeur divise une feuille de calcul Microsoft Excel à plusieurs feuilles en plusieurs feuilles de calcul Microsoft Excel où chaque feuille du fichier d’origine est convertie en une feuille de calcul individuelle dans son propre FlowFile.

SplitJson

Fractionne un fichier JSON en plusieurs FlowFiles distincts pour un élément de tableau spécifié par une expression JsonPath.

SplitRecord

Fractionne unFlowFile en entrée au format de données orienté enregistrement en plusieurs FlowFiles plus petits

SplitText

Fractionne un fichier texte en plusieurs fichiers texte plus petits sur des lignes limitées en nombre maximum de lignes ou en taille totale du fragment.

SplitXml

Fractionne un fichier XML en plusieurs FlowFiles distincts, chacun comprenant un enfant ou un descendant de l’élément racine d’origine

StartAwsPollyJob

Déclenche une tâche AWS Polly.

StartAwsTextractJob

Déclenche une tâche AWS Textract.

StartAwsTranscribeJob

Déclenche une tâche AWS Transcribe.

StartAwsTranslateJob

Déclenche une tâche AWS Translate.

StartGcpVisionAnnotateFilesOperation

Déclenche une opération Vision sur un fichier en entrée.

StartGcpVisionAnnotateImagesOperation

Déclenche une opération Vision sur une image en entrée.

Snowflake

SubmitQueryJob

Soumet une requête à Salesforce à l’aide de la fonction Bulk API 2.

Snowflake

SummarizeText

Ce processeur utilise un Large Language Model (LLM) pour résumer le contenu d’un FlowFile.

T

Processeur

Description

TagS3Object

Ajoute ou met à jour une balise sur un objet Amazon S3.

TailFile

Affiche la fin d’un fichier ou d’une liste de fichiers via la commande « Tail », en ingérant les données du fichier au fur et à mesure qu’elles y sont écrites.

TransformXml

Applique le fichier XSLT fourni à la charge utile XML du FlowFile.

U

Processeur

Description

UnpackContent

Décompresse le contenu des FlowFiles emballés avec l’un des différents formats d’empaquetage, en émettant un à plusieurs FlowFiles pour chaque FlowFile en entrée.

UpdateAttribute

Met à jour les attributs d’un FlowFile en utilisant Attribute Expression Language et/ou supprime les attributs sur la base d’une expression régulière

UpdateBoxFileMetadataInstance

Met à jour les valeurs du modèle de métadonnées pour un fichier Box en utilisant l’enregistrement dans le FlowFile donné.

UpdateByQueryElasticsearch

Met à jour les documents d’un index Elasticsearch à l’aide d’une requête.

UpdateCounter

Ce processeur permet aux utilisateurs de définir des paramètres spécifiques et des points clés dans leur flux.

UpdateDatabaseTable

Ce processeur utilise une connexion JDBC et des enregistrements entrants pour générer toutes les modifications des tables de la base de données nécessaires à la prise en charge des enregistrements entrants.

UpdateRecord

Met à jour le contenu d’un FlowFile qui contient des données orientées enregistrement (i.

Snowflake

UpdateSnowflakeDatabase

Met à jour la définition d’une table Snowflake sur la base du schéma fourni dans le FlowFile entrant.

Snowflake

UpdateSnowflakeIcebergDatabase

Met à jour la définition d’une table Snowflake Iceberg.

Snowflake

UpdateTableState

Met à jour l’état d’une table dans le service d’état des tables

Snowflake

UpsertMilvus

Insère les vecteurs dans la base de données Milvus pour une collection donnée

Snowflake

UpsertPinecone

Publie les vecteurs, y compris les métadonnées, et éventuellement le texte, dans un index Pinecone.

Snowflake

UpsertSFDCObjects

Insère via Upsert les enregistrements provenant du FlowFile dans Salesforce

V

Processeur

Description

ValidateCsv

Valide le contenu des FlowFiles ou une valeur d’attribut de FlowFile par rapport à un schéma CSV spécifié par l’utilisateur.

ValidateJson

Valide le contenu des FlowFiles par rapport à un schéma JSON configurable.

ValidateRecord

Valide les enregistrements d’un FlowFile entrant par rapport à un schéma donné.

ValidateXml

Valide le contenu XML dans un FlowFile.

VerifyContentMAC

Calcule un code d’authentification des messages à l’aide de la clé secrète fournie et le compare à la propriété MAC fournie

VerifyContentPGP

Vérifie les signatures à l’aide des clés publiques OpenPGP

W

Processeur

Description

Wait

Route les FlowFiles entrants vers la relation « wait » jusqu’à ce qu’un signal de version correspondant soit stocké dans le cache distribué à partir d’un processeur Notify correspondant.

Snowflake

WaitForTableState

Bloque les FlowFiles en entrée jusqu’à ce que l’état de la table correspondante diffère de l’état accepté.