Plug-ins Cloud Data Fusion

Ce plug-in source lit l'intégralité du contenu d'une table BigQuery.

Ce plug-in récepteur écrit dans plusieurs tables BigQuery. Les données sont d'abord écrites dans un emplacement temporaire sur Cloud Storage, puis chargées dans BigQuery à partir de là.

Ce plug-in récepteur écrit les données dans une table BigQuery. Les données sont d'abord écrites dans un emplacement temporaire sur Cloud Storage, puis chargées dans BigQuery à partir de là.

Ce plug-in source lit les objets d'un chemin d'accès dans un bucket Cloud Storage.

Ce plug-in récepteur écrit les enregistrements dans un ou plusieurs fichiers d'un répertoire Cloud Storage sous différents formats tels que CSV, Avro, Parquet et JSON.

Lit à partir de plusieurs tables d'une base de données. Utilisé avec les plug-ins multi-récepteurs, tels que les multi-récepteurs Cloud Storage et les multi-récepteurs BigQuery, pour charger des données depuis une base de données dans un seul pipeline.

Lit les données à partir d'une instance MySQL à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

Lit dans une table Oracle à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

Ce plug-in source lit les objets sObject par lot tels que les opportunités, les contacts, les comptes, les prospects, tout objet personnalisé, etc. à partir de Salesforce.

Se connecte à une source SAP pour l'extraction de données par lot et basées sur les modifications incrémentielles via le provisionnement de données opérationnelles (ODP).

Lit les données à partir de SQL Server à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

Ce plug-in source lit l'intégralité du contenu d'une table BigQuery.

Lit une table BigQuery pour récupérer les arguments à définir dans le pipeline.

Ce plug-in exécute une requête SQL BigQuery.

Ce plug-in récepteur écrit dans plusieurs tables BigQuery. Les données sont d'abord écrites dans un emplacement temporaire sur Cloud Storage, puis chargées dans BigQuery à partir de là.

Ce plug-in récepteur écrit les données dans une table BigQuery. Les données sont d'abord écrites dans un emplacement temporaire sur Cloud Storage, puis chargées dans BigQuery à partir de là.

Plug-in récepteur par lot qui écrit des données dans Cloud Bigtable.

Ce plug-in source lit les données depuis Cloud Bigtable.

Ingère des données dans n'importe quel élément compatible avec Dataplex.

Lecture des données des entités Dataplex (tables) hébergées sur des éléments Cloud Storage ou BigQuery.

Ce plug-in source lit les données à partir de Datastore. Datastore est une base de données de documents NoSQL conçue pour le scaling automatique et les hautes performances.

Ce plug-in récepteur écrit les données dans Cloud Datastore. Datastore est une base de données de documents NoSQL conçue pour le scaling automatique et les hautes performances.

Lit depuis Cloud Firestore dans des pipelines de traitement par lot.

Plug-in pour écrire dans Cloud Firestore par lot et par flux.

Ce plug-in récepteur écrit les enregistrements dans un ou plusieurs fichiers d'un répertoire Cloud Storage sous différents formats tels que CSV, Avro, Parquet et JSON.

Ce plug-in source lit les objets d'un chemin d'accès dans un bucket Cloud Storage.

Lit dans un fichier Cloud Storage pour récupérer les arguments à définir dans le pipeline.

Ce plug-in supprime des objets dans un bucket Cloud Storage.

Ce plug-in copie les objets d'un bucket Cloud Storage à un autre. Vous pouvez copier un seul objet ou un répertoire d'objets.

Ce plug-in crée des objets dans un bucket Cloud Storage.

Crée un fichier DONE (ou SUCCESS) vide dans le bucket Cloud Storage donné en cas d'achèvement, de réussite ou d'échec du pipeline afin d'orchestrer les processus dépendants.

Ce plug-in déplace les objets d'un bucket Cloud Storage à un autre. Vous pouvez déplacer un seul objet ou un répertoire d'objets.

Ce plug-in est utilisé conjointement avec la source MultiTableDatabase pour écrire des enregistrements issus de plusieurs bases de données dans des répertoires distincts.

Déchiffre les données sensibles précédemment chiffrées via Cloud Data Loss Prevention à l'aide d'une transformation de chiffrement réversible telle que le chiffrement préservant le format.

Sépare les enregistrements sensibles selon qu'ils correspondent ou non à un modèle défini par l'utilisateur à l'aide des API Cloud Data Loss Prevention.

Masque les enregistrements sensibles à l'aide de Cloud Data Loss Prevention en appliquant des filtres prédéfinis de protection contre la perte de données ou un modèle personnalisé défini par l'utilisateur.

Lit des fichiers du répertoire Google Drive spécifié via l'API Google Drive.

Ce plug-in récepteur enregistre les fichiers du pipeline dans le répertoire Google Drive via l'API Google Drive.

Écrit des feuilles de calcul dans le répertoire Google Drive spécifié.

Lit les feuilles de calcul à partir du répertoire Google Drive spécifié.

Ce plug-in récepteur écrit dans un sujet Pub/Sub dans des pipelines de traitement par flux.

Ce plug-in source lit les données depuis un abonnement Pub/Sub en temps réel.

Ce plug-in récepteur écrit dans une table Cloud Spanner.

Ce plug-in source lit les données d'une table Cloud Spanner.

Ce plug-in convertit des fichiers audio en texte à l'aide de Speech-to-Text.

Regroupe les données selon un ou plusieurs champs, puis exécute des fonctions d'agrégation telles que avg, count, count(*), first, last, max, min, sum, collect sur chaque groupe.

Joint les enregistrements d'une ou plusieurs entrées en fonction de clés de jointure. Compatible avec les jointures internes et externes, la sélection et le changement de nom des champs de sortie.

La fonction Top N renvoie les N enregistrements les plus élevés de l'ensemble d'entrées, selon les critères spécifiés dans la configuration du plug-in.

Applique les fonctions d'agrégation sur une fenêtre de données.

Envoie un e-mail à la fin de l'exécution du pipeline.

Action permettant d'envoyer un e-mail à la fin de l'exécution d'un pipeline.

Crée un fichier DONE (ou SUCCESS) vide dans le bucket Cloud Storage donné en cas d'achèvement, de réussite ou d'échec du pipeline afin d'orchestrer les processus dépendants.

Effectue une requête HTTP à la fin de l'exécution d'un pipeline.

Ce plug-in vous permet de publier des alertes sur Kafka en tant qu'objets JSON.

Exécute une requête MariaDB à la fin de l'exécution du pipeline. Peut être configuré pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Exécute une requête Netezza à la fin de l'exécution du pipeline. Peut être configuré pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Exécute une requête Oracle à la fin de l'exécution du pipeline. Peut être configuré pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Exécute une requête PostgreSQL à la fin de l'exécution du pipeline. Peut être configuré pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Exécute une requête SQL Server à la fin de l'exécution du pipeline. Peut être configuré pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Exécute une requête Teradata à la fin de l'exécution du pipeline. Peut être configuré pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Publie les alertes dans le système de messagerie transactionnelle (TMS) CDAP en tant qu'objets JSON.

Plug-in récepteur par lot qui écrit des données dans Apache Cassandra.

Plug-in source par lot qui lit des données depuis Apache Cassandra.

Écrit des enregistrements dans une table HBase avec un champ mappé à la clé de ligne, et tous les autres champs d'enregistrement mappés aux qualificatifs de colonne.

Plug-in source par lot qui lit les données d'une famille de colonnes dans une table HBase.

Hive Export prend une requête de sélection comme entrée pour exécuter cette requête sur une table Hive et stocker les résultats à l'emplacement spécifié.

Récupère des données à partir d'un point de terminaison HTTP externe et crée un fichier dans HDFS.

Ce plug-in vous permet de publier des alertes sur Kafka en tant qu'objets JSON.

Plug-in source par lot Kafka qui lit les événements d'Apache Kafka dans des pipelines de traitement par lot.

Plug-in source par flux Kafka qui lit les événements d'Apache Kafka dans des pipelines de traitement par flux.

Plug-in récepteur Kafka qui vous permet d'écrire des événements au format CSV ou JSON dans Kafka.

Exécute le code Spark fourni par l'utilisateur en Python.

Ce plug-in re-partitionne un RDD Spark.

Exécute le code Spark fourni par l'utilisateur dans Scala, qui transforme le RDD en RDD avec un accès complet à toutes les fonctionnalités Spark.

Exécute le code Spark fourni par l'utilisateur dans Scala.

Exécute le code Spark fourni par l'utilisateur dans Scala, et fonctionne sur un RDD ou un DataFrame d'entrée avec un accès complet à toutes les fonctionnalités Spark.

Analyse les journaux de n'importe quelle source d'entrée pour obtenir des informations pertinentes telles que l'URI, l'adresse IP, le navigateur, l'appareil, le code d'état HTTP et l'horodatage.

Plug-in source permettant de charger des données depuis un modèle Anaplan dans un pipeline de données.

Plug-in récepteur qui permet d'importer des données de CDAP vers le serveur Anaplan.

Effectue une action/un processus prédéfini dans le modèle Anaplan donné. Ce type de certificat est le plus souvent utilisé pour vous préparer à l'importation et à l'exportation de données.

Lit les données d'annonces de l'API Facebook Insights dans des pipelines de traitement par lot.

Lit à partir de Google Analytics 360 dans les pipelines de traitement par lot.

Lit à partir de Google Analytics 360 dans des pipelines de traitement par flux.

Lit des fichiers du répertoire Google Drive spécifié via l'API Google Drive.

Ce plug-in récepteur enregistre les fichiers du pipeline dans le répertoire Google Drive via l'API Google Drive.

Écrit des feuilles de calcul dans le répertoire Google Drive spécifié.

Lit les feuilles de calcul à partir du répertoire Google Drive spécifié.

Lit les données aux formats JSON, XML, CSV, TSV, TEXT et BLOB à partir des API HTTP/HTTPS dans des pipelines de traitement par lot.

Plug-in récepteur qui envoie les messages du pipeline à un point de terminaison HTTP externe.

Effectue une requête HTTP à la fin de l'exécution d'un pipeline.

Plug-in source par flux qui récupère des données à partir d'une URL spécifiée à un intervalle donné, puis transmet les résultats au plug-in suivant.

Lit les données aux formats JSON, XML, CSV, TSV, TEXT et BLOB à partir des API HTTP/HTTPS dans des pipelines de traitement par flux.

Récupère des données à partir d'un point de terminaison HTTP externe et crée un fichier dans HDFS.

Plug-in permettant d'écrire des données dans HubSpot CRM dans des pipelines de traitement par lot et par flux.

Lit les données de HubSpot CRM dans des pipelines de traitement par flux.

Lit les données de HubSpot CRM dans des pipelines de traitement par lot.

Ce plug-in source lit les objets sObject par lot tels que les opportunités, les contacts, les comptes, les prospects, tout objet personnalisé, etc. à partir de Salesforce.

Ce plug-in source effectue le suivi des mises à jour dans les objets sObject Salesforce. Les objets sObject peuvent être des opportunités, des contacts, des comptes, des prospects, tout objet personnalisé, etc.

Plug-in récepteur par lot qui insère des objets sObject tels que des opportunités, des contacts, des comptes, des prospects, tout objet personnalisé, etc. dans Salesforce.

Ce plug-in source effectue le suivi des mises à jour dans les objets sObject Salesforce, tels que les opportunités, les contacts, les comptes, les prospects, tout objet personnalisé, etc.

Ce plug-in récepteur insère des enregistrements dans une extension de données Salesforce Marketing Cloud (SFMC) via une intégration de serveur à serveur avec l'API SFMC.

Ce plug-in source lit plusieurs objets sObject de Salesforce. Elle doit être utilisée avec des multi-récepteurs.

Lit les données d'une ou de plusieurs tables dans ServiceNow.

Ce plug-in convertit des fichiers audio en texte à l'aide de Speech-to-Text.

Lit les objets tels que les commentaires (sur des articles, des publications, des requêtes, des demandes d'assistance), les groupes, les organisations, les avis de satisfaction, les tags, les demandes d'assistance (et les champs, métriques et événements de métrique associés) et les utilisateurs à partir de Zendesk.

Plug-in multi-source qui lit plusieurs objets depuis Zendesk et les achemine vers des destinations spécifiques. À utiliser avec un multi-récepteur.

Écrit dans un système de fichiers sous divers formats.

Ce plug-in source est utilisé chaque fois que vous devez lire des données à partir d'un système de fichiers distribué.

Écrit des enregistrements dans un ou plusieurs fichiers d'un répertoire Cloud Storage sous différents formats tels que CSV, Avro, Parquet et JSON.

Ce plug-in source est utilisé chaque fois que vous avez besoin de lire des données depuis Amazon S3.

Ce plug-in récepteur permet d'écrire dans Amazon S3 sous divers formats.

L'action Client Amazon S3 permet de travailler avec des buckets et des objets S3 avant ou après l'exécution d'un pipeline.

Déduplique les enregistrements à l'aide d'un ou de plusieurs champs, ou à l'aide de l'enregistrement dans son ensemble. Permet également de choisir logiquement un enregistrement parmi les enregistrements en double en fonction d'un champ de filtre. Les fonctions logiques compatibles sont "max", "min", "first" et "last".

Déduplique les enregistrements d'entrée afin que tous les enregistrements de sortie soient distincts.

Filtre les messages en fonction d'un critère spécifié.

Sépare les enregistrements sensibles selon qu'ils correspondent ou non à un modèle défini par l'utilisateur à l'aide des API Cloud Data Loss Prevention.

Ce plug-in applique des instructions de transformation de données générées via une interface utilisateur interactive ou manuellement sur vos enregistrements de données.

Ce plug-in source est utilisé chaque fois que vous avez besoin de lire des données depuis Amazon S3.

Plug-in source par lot pour utiliser Microsoft Azure Blob Storage comme source.

Charge des données à partir de fichiers externes ou internes en préproduction dans Cloud Storage vers une table Snowflake existante.

Ce plug-in récepteur écrit les enregistrements dans un ou plusieurs fichiers d'un répertoire Cloud Storage sous différents formats tels que CSV, Avro, Parquet et JSON.

Ce plug-in lit les objets d'un chemin d'accès dans un bucket Cloud Storage.

Lit dans un fichier Cloud Storage pour récupérer les arguments à définir dans le pipeline.

Ce plug-in supprime des objets dans un bucket Cloud Storage.

Ce plug-in copie les objets d'un bucket Cloud Storage à un autre. Vous pouvez copier un seul objet ou un répertoire d'objets.

Ce plug-in crée des objets dans un bucket Cloud Storage.

Ce plug-in déplace les objets d'un bucket Cloud Storage à un autre. Vous pouvez déplacer un seul objet ou un répertoire d'objets.

Ce plug-in est utilisé conjointement avec la source MultiTableDatabase pour écrire des enregistrements issus de plusieurs bases de données dans des répertoires distincts.

Crée un fichier DONE (ou SUCCESS) vide dans le bucket Cloud Storage donné en cas d'achèvement, de réussite ou d'échec du pipeline afin d'orchestrer les processus dépendants.

Exécute le code JavaScript fourni par l'utilisateur qui transforme un enregistrement en zéro ou plusieurs enregistrements.

Exécute le code Spark fourni par l'utilisateur en Python.

Exécute le code Python fourni par l'utilisateur pour transformer les enregistrements d'entrée, qui sont disponibles en tant que dictionnaire Python.

Exécute le code Spark fourni par l'utilisateur dans Scala, qui transforme le RDD en RDD avec un accès complet à toutes les fonctionnalités Spark.

Exécute le code Spark fourni par l'utilisateur dans Scala.

Exécute le code Spark fourni par l'utilisateur dans Scala, et fonctionne sur un RDD ou un DataFrame d'entrée avec un accès complet à toutes les fonctionnalités Spark.

Compresse les champs configurés à l'aide de différents algorithmes de compression, tels que SNAPPY, ZIP et GZIP.

Décompresse les champs configurés à l'aide d'algorithmes de compression tels que SNAPPY, ZIP et GZIP.

Plug-in de flux de contrôle permettant une exécution conditionnelle dans les pipelines en fonction d'expressions.

Collecte les erreurs émises à l'étape précédente, et ajoute un message d'erreur, un code et une étape à l'enregistrement.

Plug-in récepteur par lot qui entraîne l'échec d'un pipeline immédiatement après la réception du premier enregistrement.

Ce plug-in envoie les enregistrements associés à une valeur nulle pour un champ donné au port nul et ceux associés à une valeur non nulle au port non nul.

Achemine un enregistrement vers un port approprié en fonction de l'évaluation d'une expression sur la valeur d'un ou de plusieurs champs.

Le séparateur d'union est utilisé pour répartir les données selon un schéma d'union, de sorte que la logique spécifique au type puisse être effectuée en aval.

Effectue une action/un processus prédéfini dans le modèle Anaplan donné. Ce type de certificat est le plus souvent utilisé pour vous préparer à l'importation et à l'exportation de données.

Exécute une requête SQL au début ou à la fin d'un pipeline.

Plug-in d'action qui exécute une commande de base de données.

Exécute une requête de base de données à la fin de l'exécution du pipeline. Peut être configuré pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Plug-in d'action qui exécute une commande DB2.

Ce plug-in d'action permet de vérifier si un fichier est vide ou si le contenu d'un fichier correspond à un format donné.

Supprime un ou plusieurs fichiers.

Permet de déplacer un ou plusieurs fichiers.

Permet de copier les fichiers du serveur FTP vers la destination indiquée.

Permet de copier des fichiers sur le serveur FTP à partir d'une destination spécifiée.

Ce plug-in supprime des objets dans un bucket Cloud Storage.

Ce plug-in copie les objets d'un bucket Cloud Storage à un autre. Vous pouvez copier un seul objet ou un répertoire d'objets.

Ce plug-in crée des objets dans un bucket Cloud Storage.

Ce plug-in déplace les objets d'un bucket Cloud Storage à un autre. Vous pouvez déplacer un seul objet ou un répertoire d'objets.

Récupère des données à partir d'un point de terminaison HTTP externe et crée un fichier dans HDFS.

Plug-in d'action qui exécute une commande MariaDB.

Plug-in d'action qui exécute une commande MySQL.

Plug-in d'action qui exécute une commande Netezza.

Plug-in d'action qui exécute une commande Oracle.

Plug-in d'action permettant d'exporter efficacement les données Oracle vers un système de fichiers à l'aide des outils de ligne de commande d'Oracle.

Plug-in d'action qui exécute une commande PostgreSQL.

Établit une connexion SSH avec une machine distante pour exécuter la commande sur cette machine.

La copie SFTP permet de copier les fichiers du répertoire spécifié sur les serveurs SFTP vers la destination indiquée.

Plug-in d'action CDAP pour supprimer les fichiers spécifiés d'un serveur SFTP.

La fonctionnalité SFTP Put permet d'importer les fichiers du système de fichiers (local/HDFS) sur le serveur FTP. Vous pouvez également utiliser des expressions régulières pour cibler uniquement les fichiers qui vous intéressent.

Exécute une requête SQL spécifiée dans Snowflake.

Plug-in d'action qui exécute une commande SQL Server.

Plug-in d'action qui exécute une commande Teradata.

Copie un ou plusieurs fichiers d'un partage Microsoft Windows sur un système de fichiers.

Plug-in permettant d'écrire des données dans HubSpot CRM dans des pipelines de traitement par lot et par flux.

Lit les données de HubSpot CRM dans des pipelines de traitement par flux.

Lit les données de HubSpot CRM dans des pipelines de traitement par lot.

Ce plug-in source lit les objets sObject par lot tels que les opportunités, les contacts, les comptes, les prospects, tout objet personnalisé, etc. à partir de Salesforce.

Plug-in récepteur par lot qui insère des objets sObject tels que des opportunités, des contacts, des comptes, des prospects, tout objet personnalisé, etc. dans Salesforce.

Ce plug-in source effectue le suivi des mises à jour dans les objets sObject Salesforce. Les objets sObject peuvent être des opportunités, des contacts, des comptes, des prospects, tout objet personnalisé, etc.

Ce plug-in source effectue le suivi des mises à jour dans les objets sObject Salesforce, tels que les opportunités, les contacts, les comptes, les prospects, tout objet personnalisé, etc.

Ce plug-in récepteur insère des enregistrements dans une extension de données Salesforce Marketing Cloud (SFMC) via une intégration de serveur à serveur avec l'API SFMC.

Ce plug-in source lit plusieurs objets sObject de Salesforce. Elle doit être utilisée avec des multi-récepteurs.

Met en forme la saisie dans un enregistrement CSV à l'aide de formats tels que DÉLIMITÉ, EXCEL, MYSQL, RFC4180 et TDF.

Analyse un enregistrement CSV au format PAR DÉFAUT, EXCEL, MYSQL, RFC4180, délimité par des tabulations ou délimité par des barres verticales dans un enregistrement structuré.

Écrit dans un système de fichiers sous divers formats.

Ce plug-in source est utilisé chaque fois que vous devez lire des données à partir d'un système de fichiers distribué.

Ce plug-in récepteur écrit les enregistrements dans un ou plusieurs fichiers d'un répertoire Cloud Storage sous différents formats tels que CSV, Avro, Parquet et JSON.

Plug-in récepteur Kafka qui vous permet d'écrire des événements au format CSV ou JSON dans Kafka.

Plug-in récepteur par lot qui écrit des données dans Cloud Bigtable.

Ce plug-in source lit les données depuis Cloud Bigtable.

Plug-in d'action qui exécute une commande de base de données.

Lit les données à partir d'une base de données à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

Écrit des enregistrements dans une table de base de données. Chaque enregistrement est écrit dans une ligne de la table.

Lit une table de base de données relationnelle pour récupérer les arguments à définir dans le pipeline.

Exécute une requête de base de données à la fin de l'exécution du pipeline. Peut être configuré pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Lit les données à partir d'une table DB2 à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

Exécute une requête DB2 à la fin de l'exécution du pipeline. Peut être configuré pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Plug-in d'action qui exécute une commande DB2.

Écrit des enregistrements dans une table DB2. Chaque enregistrement est écrit dans une ligne de la table.

Écrit des enregistrements dans une table MariaDB. Chaque enregistrement est écrit dans une ligne de la table.

Lit les données à partir d'une table MariaDB à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

Exécute une requête MariaDB à la fin de l'exécution du pipeline. Peut être configuré pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Plug-in d'action qui exécute une commande MariaDB.

Lit à partir de plusieurs tables d'une base de données. Utilisé avec les plug-ins multi-récepteurs, tels que les multi-récepteurs Cloud Storage et les multi-récepteurs BigQuery, pour charger des données depuis une base de données dans un seul pipeline.

Exécute une requête MySQL à la fin de l'exécution du pipeline. Peut être configuré pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Écrit des enregistrements dans une table MySQL. Chaque enregistrement est écrit dans une ligne de la table.

Lit les données à partir d'une instance MySQL à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

Plug-in d'action qui exécute une commande MySQL.

Lit dans une table Oracle à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

Écrit des enregistrements dans une table Oracle. Chaque enregistrement est écrit dans une ligne de la table.

Exécute une requête Oracle à la fin de l'exécution du pipeline. Peut être configuré pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Plug-in d'action qui exécute une commande Oracle.

Plug-in d'action permettant d'exporter efficacement les données Oracle vers un système de fichiers à l'aide des outils de ligne de commande d'Oracle.

Lit les données à partir d'une table PostgreSQL à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

Écrit des enregistrements dans une table PostgreSQL. Chaque enregistrement est écrit dans une ligne de la table.

Exécute une requête PostgreSQL à la fin de l'exécution du pipeline. Peut être configuré pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Plug-in d'action qui exécute une commande PostgreSQL.

Ce plug-in récepteur écrit dans une table Cloud Spanner.

Ce plug-in source lit les données d'une table Cloud Spanner.

Écrit des enregistrements dans une table SQL Server. Chaque enregistrement est écrit dans une ligne de la table.

Exécute une requête SQL Server à la fin de l'exécution du pipeline. Peut être configuré pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Lit les données à partir de SQL Server à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

Plug-in d'action qui exécute une commande SQL Server.

DB2 exécute une requête DB2 à la fin de l'exécution du pipeline. Peut être configuré pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Ce plug-in source lit l'intégralité du contenu d'une table BigQuery.

Lit une table BigQuery pour récupérer les arguments à définir dans le pipeline.

Ce plug-in exécute une requête SQL BigQuery.

Ce plug-in récepteur écrit dans plusieurs tables BigQuery. Les données sont d'abord écrites dans un emplacement temporaire sur Cloud Storage, puis chargées dans BigQuery à partir de là.

Ce plug-in récepteur écrit les données dans une table BigQuery. Les données sont d'abord écrites dans un emplacement temporaire sur Cloud Storage, puis chargées dans BigQuery à partir de là.

Charge des données à partir de fichiers externes ou internes en préproduction dans Cloud Storage vers une table Snowflake existante.

Hive Export prend une requête de sélection comme entrée pour exécuter cette requête sur une table Hive et stocker les résultats à l'emplacement spécifié.

Écrit des enregistrements dans une table Netezza. Chaque enregistrement est écrit dans une ligne de la table.

Lit les données à partir d'une table Netezza à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

Exécute une requête Netezza à la fin de l'exécution du pipeline. Peut être configuré pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Plug-in d'action qui exécute une commande Netezza.

Crée une représentation SCD2 d'un enregistrement en regroupant les enregistrements sources par la clé spécifiée et en générant les dates de début et de fin (expiration).

Écrit des données dans une table Snowflake dans des pipelines de traitement par lot.

Lit les données des tables Snowflake dans des pipelines de traitement par lot.

Exécute une requête SQL spécifiée dans Snowflake.

Écrit des enregistrements dans une table Teradata. Chaque enregistrement est écrit dans une ligne de la table.

Lit les données à partir de Teradata à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

Exécute une requête Teradata à la fin de l'exécution du pipeline. Peut être configuré pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Plug-in d'action qui exécute une commande Teradata.

Déchiffre les données sensibles précédemment chiffrées via Cloud Data Loss Prevention à l'aide d'une transformation de chiffrement réversible telle que le chiffrement préservant le format.

Sépare les enregistrements sensibles selon qu'ils correspondent ou non à un modèle défini par l'utilisateur à l'aide des API Cloud Data Loss Prevention.

Masque les enregistrements sensibles à l'aide de Cloud Data Loss Prevention en appliquant des filtres prédéfinis de protection contre la perte de données ou un modèle personnalisé défini par l'utilisateur.

Effectue une requête HTTP pour récupérer les arguments à définir dans le pipeline.

Lit une table de base de données relationnelle pour récupérer les arguments à définir dans le pipeline.

Lit dans un fichier Cloud Storage pour récupérer les arguments à définir dans le pipeline.

Envoie un e-mail à la fin de l'exécution du pipeline.

Action permettant d'envoyer un e-mail à la fin de l'exécution d'un pipeline.

Lit les données sur les campagnes marketing existantes, les analyses d'e-mails, les rebonds et les rapports de spam depuis SendGrid.

Écrit des données dans SendGrid par lot et par flux.

Met en forme la saisie dans un enregistrement CSV à l'aide de formats tels que DÉLIMITÉ, EXCEL, MYSQL, RFC4180 et TDF.

Analyse un enregistrement CSV au format PAR DÉFAUT, EXCEL, MYSQL, RFC4180, délimité par des tabulations ou délimité par des barres verticales dans un enregistrement structuré.

Écrit dans un système de fichiers sous divers formats.

Ce plug-in source est utilisé chaque fois que vous devez lire des données à partir d'un système de fichiers distribué.

Plug-in source par flux de fichiers qui surveille un répertoire et transmet le contenu des nouveaux fichiers qui y sont ajoutés.

Ce plug-in récepteur ajoute du contenu à un fichier existant jusqu'à ce qu'il atteigne un seuil d'âge ou une taille.

Ce plug-in d'action permet de vérifier si un fichier est vide ou si le contenu d'un fichier correspond à un format donné.

Supprime un ou plusieurs fichiers.

Permet de déplacer un ou plusieurs fichiers.

Plug-in source par lot qui lit à partir de FTP (ftp://..) ou SFTP (sftp://...).

Permet de copier les fichiers du serveur FTP vers la destination indiquée.

Permet de copier des fichiers sur le serveur FTP à partir d'une destination spécifiée.

Cette transformation exploite la bibliothèque Apache PDF Box pour extraire le texte et les métadonnées d'un fichier PDF.

Ce plug-in récepteur permet d'écrire dans Amazon S3 sous divers formats.

La copie SFTP permet de copier les fichiers du répertoire spécifié sur les serveurs SFTP vers la destination indiquée.

Plug-in d'action CDAP pour supprimer les fichiers spécifiés d'un serveur SFTP.

La fonctionnalité SFTP Put permet d'importer les fichiers du système de fichiers (local/HDFS) sur le serveur FTP. Vous pouvez également utiliser des expressions régulières pour cibler uniquement les fichiers qui vous intéressent.

Déduplique les enregistrements à l'aide d'un ou de plusieurs champs, ou à l'aide de l'enregistrement dans son ensemble. Permet également de choisir logiquement un enregistrement parmi les enregistrements en double en fonction d'un champ de filtre. Les fonctions logiques compatibles sont "max", "min", "first" et "last".

Déduplique les enregistrements d'entrée afin que tous les enregistrements de sortie soient distincts.

Filtre les messages en fonction d'un critère spécifié.

Sépare les enregistrements sensibles selon qu'ils correspondent ou non à un modèle défini par l'utilisateur à l'aide des API Cloud Data Loss Prevention.

Ce plug-in envoie les enregistrements associés à une valeur nulle pour un champ donné au port nul et ceux associés à une valeur non nulle au port non nul.

Cette méthode échantillonne un ensemble de données volumineux circulant à l'aide de ce plug-in pour extraire des enregistrements aléatoires en utilisant un échantillonnage systématique ou "réservoir".

La fonction Top N renvoie les N enregistrements les plus élevés de l'ensemble d'entrées, selon les critères spécifiés dans la configuration du plug-in.

Plug-in source par lot qui lit à partir de FTP (ftp://..) ou SFTP (sftp://...).

Permet de copier les fichiers du serveur FTP vers la destination indiquée.

Permet de copier des fichiers sur le serveur FTP à partir d'une destination spécifiée.

La copie SFTP permet de copier les fichiers du répertoire spécifié sur les serveurs SFTP vers la destination indiquée.

Plug-in d'action CDAP pour supprimer les fichiers spécifiés d'un serveur SFTP.

La fonctionnalité SFTP Put permet d'importer les fichiers du système de fichiers (local/HDFS) sur le serveur FTP. Vous pouvez également utiliser des expressions régulières pour cibler uniquement les fichiers qui vous intéressent.

Lit à partir de Google Analytics 360 dans les pipelines de traitement par lot.

Lit à partir de Google Analytics 360 dans des pipelines de traitement par flux.

Lit des fichiers du répertoire Google Drive spécifié via l'API Google Drive.

Ce plug-in récepteur enregistre les fichiers du pipeline dans le répertoire Google Drive via l'API Google Drive.

Lit les feuilles de calcul à partir du répertoire Google Drive spécifié.

Écrit des feuilles de calcul dans le répertoire Google Drive spécifié.

Écrit des enregistrements dans une table HBase avec un champ mappé à la clé de ligne, et tous les autres champs d'enregistrement mappés aux qualificatifs de colonne.

Plug-in source par lot qui lit les données d'une famille de colonnes dans une table HBase.

Hive Export prend une requête de sélection comme entrée pour exécuter cette requête sur une table Hive et stocker les résultats à l'emplacement spécifié.

Récupère des données à partir d'un point de terminaison HTTP externe et crée un fichier dans HDFS.

Plug-in source qui permet aux utilisateurs de lire des fichiers XML stockés sur HDFS.

Récupère des données à partir d'un point de terminaison HTTP externe et crée un fichier dans HDFS.

Effectue une requête HTTP pour récupérer les arguments à définir dans le pipeline.

Lit les données à partir d'une table DB2 à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

Exécute une requête DB2 à la fin de l'exécution du pipeline. Peut être configuré pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Plug-in d'action qui exécute une commande DB2.

Écrit des enregistrements dans une table DB2. Chaque enregistrement est écrit dans une ligne de la table.

Écrit des enregistrements dans une table Netezza. Chaque enregistrement est écrit dans une ligne de la table.

Lit les données à partir d'une table Netezza à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

Exécute une requête Netezza à la fin de l'exécution du pipeline. Peut être configuré pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Plug-in d'action qui exécute une commande Netezza.

Lit les données à partir d'une base de données à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

Écrit des enregistrements dans une table de base de données. Chaque enregistrement est écrit dans une ligne de la table.

Lit les documents d'une collection MongoDB et convertit chaque document en un StructuredRecord à l'aide d'un schéma spécifié.

Ce plug-in récepteur écrit dans une collection MongoDB.

Exécute une requête MySQL à la fin de l'exécution du pipeline. Peut être configuré pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Écrit des enregistrements dans une table MySQL. Chaque enregistrement est écrit dans une ligne de la table.

Lit les données à partir d'une instance MySQL à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

Plug-in d'action qui exécute une commande MySQL.

Écrit des enregistrements dans une table Netezza. Chaque enregistrement est écrit dans une ligne de la table.

Lit les données à partir d'une table Netezza à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

Exécute une requête Netezza à la fin de l'exécution du pipeline. Peut être configuré pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Plug-in d'action qui exécute une commande Netezza.

Lit dans une table Oracle à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

Écrit des enregistrements dans une table Oracle. Chaque enregistrement est écrit dans une ligne de la table.

Exécute une requête Oracle à la fin de l'exécution du pipeline. Peut être configuré pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Plug-in d'action qui exécute une commande Oracle.

Plug-in d'action permettant d'exporter efficacement les données Oracle vers un système de fichiers à l'aide des outils de ligne de commande d'Oracle.

Lit les données à partir d'une table PostgreSQL à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

Écrit des enregistrements dans une table PostgreSQL. Chaque enregistrement est écrit dans une ligne de la table.

Exécute une requête PostgreSQL à la fin de l'exécution du pipeline. Peut être configuré pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Plug-in d'action qui exécute une commande PostgreSQL.

Écrit des enregistrements dans une table SQL Server. Chaque enregistrement est écrit dans une ligne de la table.

Exécute une requête SQL Server à la fin de l'exécution du pipeline. Peut être configuré pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Lit les données à partir de SQL Server à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

Plug-in d'action qui exécute une commande SQL Server.

Écrit des enregistrements dans une table Teradata. Chaque enregistrement est écrit dans une ligne de la table.

Lit les données à partir de Teradata à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

Exécute une requête Teradata à la fin de l'exécution du pipeline. Peut être configuré pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Plug-in d'action qui exécute une commande Teradata.

Écrit les données dans Elasticsearch sous forme de chaîne JSON, puis les indexe à l'aide de l'index, du type et de l'idField spécifiés par l'utilisateur.

Écrit des enregistrements dans un ou plusieurs fichiers d'un répertoire sur Cloud Storage sous différents formats tels que CSV, Avro, Parquet et JSON.

Met en forme un enregistrement structuré en tant qu'objet JSON.

Analyse un événement JSON en entrée dans un enregistrement à l'aide de chemins JSON pour extraire des champs d'entrées JSON complexes imbriqués.

Plug-in récepteur Kafka qui vous permet d'écrire des événements au format CSV ou JSON dans Kafka.

Accepte un champ qui contient une chaîne XML correctement formatée et en génère une version JSON correctement formatée.

Lit à partir de Confluent Kafka dans des pipelines de traitement par flux.

Plug-in permettant d'écrire dans Confluent Kafka dans des pipelines de traitement par flux.

Plug-in source par lot Kafka qui lit les événements d'Apache Kafka dans des pipelines de traitement par lot.

Plug-in source par flux Kafka qui lit les événements d'Apache Kafka dans des pipelines de traitement par flux.

Ce plug-in vous permet de publier des alertes sur Kafka en tant qu'objets JSON.

Plug-in récepteur Kafka qui vous permet d'écrire des événements au format CSV ou JSON dans Kafka.

Analyse les journaux de n'importe quelle source d'entrée pour obtenir des informations pertinentes telles que l'URI, l'adresse IP, le navigateur, l'appareil, le code d'état HTTP et l'horodatage.

Ajoute un nouveau champ à chaque enregistrement. La valeur du champ peut être un nouvel UUID ou être définie directement via la configuration.

Crée une copie de chaque enregistrement d'entrée reçu un nombre défini de fois dans la sortie.

Plug-in permettant de générer des structures hiérarchiques à partir de schémas plats.

Ce plug-in convertit une date dans une chaîne ou dans un horodatage Unix en chaîne formatée. (Compatible avec les macros.)

Masque les enregistrements sensibles à l'aide de Cloud Data Loss Prevention en appliquant des filtres prédéfinis de protection contre la perte de données ou un modèle personnalisé défini par l'utilisateur.

Effectue une recherche d'un champ donné dans un ensemble de données de recherche en l'associant à l'ensemble de données d'entrée. Inclut le champ puis sa valeur dans l'ensemble de données obtenu.

Ce plug-in de transformation vous permet d'ajouter un ou plusieurs champs à la sortie.

Plug-in de transformation qui vous permet de déposer, de conserver, de renommer et de caster des champs de type différent.

À partir d'un champ et d'un délimiteur, émet un enregistrement pour chaque division du champ.

Convertit des données brutes en données dénormalisées en fonction d'une colonne de clé.

Crée une représentation SCD2 d'un enregistrement en regroupant les enregistrements sources par la clé spécifiée et en générant les dates de début et de fin (expiration).

Normalise les données en convertissant les colonnes en lignes.

Value Mapper est un plug-in de transformation qui mappe les valeurs de chaîne d'un champ de l'enregistrement d'entrée à une valeur de mappage à l'aide d'un ensemble de données de mappage.

Ce plug-in applique des instructions de transformation de données générées via une interface utilisateur interactive ou manuellement sur vos enregistrements de données.

Décode les champs configurés à l'aide de méthodes de décodage telles que STRING_BASE64, BASE64, BASE32, STRING_BASE32 et HEX.

Déchiffre un ou plusieurs champs des enregistrements d'entrée à l'aide d'un keystore qui doit être présent sur tous les nœuds du cluster.

Chiffre un ou plusieurs champs des enregistrements d'entrée à l'aide d'un keystore Java qui doit être présent sur tous les nœuds du cluster.

Encode les champs configurés à l'aide de méthodes d'encodage telles que STRING_BASE64, BASE64, BASE32, STRING_BASE32 et HEX.

Encode les valeurs de champ à l'aide d'algorithmes de condensé tels que MD2, MD5, SHA1, SHA256, SHA384 et SHA512.

Le plug-in Excel permet à l'utilisateur de lire les données d'un ou de plusieurs fichiers Excel.

Copie un ou plusieurs fichiers d'un partage Microsoft Windows sur un système de fichiers.

Écrit des données dans le répertoire Azure Data Lake Store au format Avro, Orc ou texte.

Ce plug-in récepteur écrit dans plusieurs répertoires Azure Data Lake.

Plug-in source par lot pour utiliser Microsoft Azure Blob Storage comme source.

Plug-in source par lot qui lit les données des fichiers Azure Data Lake Store et les convertit en StructuredRecord.

Exécute une requête SQL Server à la fin de l'exécution du pipeline. Peut être configuré pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Lit les données à partir de SQL Server à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

Écrit des enregistrements dans une table SQL Server. Chaque enregistrement est écrit dans une ligne de la table.

Plug-in d'action qui exécute une commande SQL Server.

Plug-in permettant de transformer des données imbriquées en données plates.

Plug-in récepteur par lot qui écrit des données dans Apache Cassandra.

Plug-in source par lot qui lit des données depuis Apache Cassandra.

Ce plug-in source lit les données à partir de Datastore. Datastore est une base de données de documents NoSQL conçue pour le scaling automatique et les hautes performances.

Ce plug-in récepteur écrit les données dans Cloud Datastore. Datastore est une base de données de documents NoSQL conçue pour le scaling automatique et les hautes performances.

Lit depuis Cloud Firestore dans des pipelines de traitement par lot.

Plug-in pour écrire dans Cloud Firestore par lot et par flux.

Écrit des enregistrements dans une table HBase avec un champ mappé à la clé de ligne, et tous les autres champs d'enregistrement mappés aux qualificatifs de colonne.

Plug-in source par lot qui lit les données d'une famille de colonnes dans une table HBase.

Lit les documents d'une collection MongoDB et convertit chaque document en un StructuredRecord à l'aide d'un schéma spécifié.

Ce plug-in récepteur écrit dans une collection MongoDB.

Lit dans une table Oracle à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

Écrit des enregistrements dans une table Oracle. Chaque enregistrement est écrit dans une ligne de la table.

Exécute une requête Oracle à la fin de l'exécution du pipeline. Peut être configuré pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Plug-in d'action qui exécute une commande Oracle.

Plug-in d'action permettant d'exporter efficacement les données Oracle vers un système de fichiers à l'aide des outils de ligne de commande d'Oracle.

Écrit dans un système de fichiers sous divers formats.

Ce plug-in source est utilisé chaque fois que vous devez lire des données à partir d'un système de fichiers distribué.

Écrit des enregistrements dans un ou plusieurs fichiers d'un répertoire Cloud Storage sous différents formats tels que CSV, Avro, Parquet et JSON.

Exécute le code Spark fourni par l'utilisateur en Python.

Exécute le code Python fourni par l'utilisateur pour transformer les enregistrements d'entrée, qui sont disponibles en tant que dictionnaire Python.

Ce plug-in source est utilisé chaque fois que vous avez besoin de lire des données depuis Amazon S3.

Accélère la fonctionnalité d'extraction par lot des tables SAP pour le processus de commande de trésorerie.

Accélère la fonctionnalité d'extraction par lot des tables SAP pour le processus "procure-to-pay".

Se connecte à une source SAP Ariba pour intégrer des données par lot dans Google Cloud.

Se connecte à une source SAP pour une extraction par lot et basée sur les modifications incrémentielles via le service BW Open Hub.

Se connecte à une source SAP pour l'extraction de données par lot à l'aide du protocole OData (Open Data Protocol).

Se connecte à une source SAP pour l'extraction de données par lot et basées sur les modifications incrémentielles via le provisionnement de données opérationnelles (ODP).

Se connecte à une source SAP pour répliquer les données dans Google Cloud à l'aide de SAP Landscape Transformation (SLT).

Se connecte à une source SAP pour extraire des données par lot.

Se connecte à une source SAP pour transférer des données de façon groupée à partir de tables et de vues SAP.

Plug-in source permettant de charger des données depuis un modèle Anaplan dans un pipeline de données.

Plug-in récepteur qui permet d'importer des données de CDAP vers le serveur Anaplan.

Effectue une action/un processus prédéfini dans le modèle Anaplan donné. Ce type de certificat est le plus souvent utilisé pour vous préparer à l'importation et à l'exportation de données.

Plug-in permettant d'écrire des données dans HubSpot CRM dans des pipelines de traitement par lot et par flux.

Lit les données de HubSpot CRM dans des pipelines de traitement par flux.

Lit les données de HubSpot CRM dans des pipelines de traitement par lot.

Ce plug-in source lit les objets sObject par lot tels que les opportunités, les contacts, les comptes, les prospects, tout objet personnalisé, etc. à partir de Salesforce.

Plug-in récepteur par lot qui insère des objets sObject tels que des opportunités, des contacts, des comptes, des prospects, tout objet personnalisé, etc. dans Salesforce.

Ce plug-in source effectue le suivi des mises à jour dans les objets sObject Salesforce, tels que les opportunités, les contacts, les comptes, les prospects, tout objet personnalisé, etc.

Ce plug-in récepteur insère des enregistrements dans une extension de données Salesforce Marketing Cloud (SFMC) via une intégration de serveur à serveur avec l'API SFMC.

Ce plug-in source lit plusieurs objets sObject de Salesforce. Elle doit être utilisée avec des multi-récepteurs.

Lit les données d'une ou de plusieurs tables dans ServiceNow.

Lit les objets tels que les commentaires (sur des articles, des publications, des requêtes, des demandes d'assistance), les groupes, les organisations, les avis de satisfaction, les tags, les demandes d'assistance (et les champs, métriques et événements de métrique associés) et les utilisateurs à partir de Zendesk.

Plug-in multi-source qui lit plusieurs objets depuis Zendesk et les achemine vers des destinations spécifiques. À utiliser avec un multi-récepteur.

Extrait des documents d'Elasticsearch en fonction de la requête spécifiée par l'utilisateur.

Écrit les données dans Elasticsearch sous forme de chaîne JSON, puis les indexe à l'aide de l'index, du type et de l'idField spécifiés par l'utilisateur.

Charge des données à partir de fichiers externes ou internes en préproduction dans Cloud Storage vers une table Snowflake existante.

Écrit des données dans une table Snowflake dans des pipelines de traitement par lot.

Lit les données des tables Snowflake dans des pipelines de traitement par lot.

Exécute une requête SQL spécifiée dans Snowflake.

Analyse les journaux de n'importe quelle source d'entrée pour obtenir des informations pertinentes telles que l'URI, l'adresse IP, le navigateur, l'appareil, le code d'état HTTP et l'horodatage.

Exécute le code Spark fourni par l'utilisateur en Python.

Ce plug-in re-partitionne un RDD Spark.

Exécute le code Spark fourni par l'utilisateur dans Scala, qui transforme le RDD en RDD avec un accès complet à toutes les fonctionnalités Spark.

Exécute le code Spark fourni par l'utilisateur dans Scala.

Exécute le code Spark fourni par l'utilisateur dans Scala, et fonctionne sur un RDD ou un DataFrame d'entrée avec un accès complet à toutes les fonctionnalités Spark.

Établit une connexion SSH avec une machine distante pour exécuter la commande sur cette machine.

Exécute un binaire qui est installé et disponible sur le système de fichiers local des nœuds Hadoop.

Calcule des statistiques telles que le total, les valeurs nulles, les valeurs min, max, moyenne, stddev, zéro, le nombre positif et le nombre négatif.

Regroupe les données selon un ou plusieurs champs, puis exécute des fonctions d'agrégation telles que avg, count, count(*), first, last, max, min, sum, collect sur chaque groupe.

Lit à partir d'Amazon Simple Queue Service (SQS) dans des pipelines de traitement par flux.

Plug-in permettant d'écrire dans Amazon Simple Queue Service (SQS) dans des pipelines de traitement par flux.

Lit à partir de Confluent Kafka dans des pipelines de traitement par flux.

Plug-in permettant d'écrire dans Confluent Kafka dans des pipelines de traitement par flux.

Plug-in source par flux de fichiers qui surveille un répertoire et transmet le contenu des nouveaux fichiers qui y sont ajoutés.

Lit à partir de Google Analytics 360 dans des pipelines de traitement par flux.

Plug-in source par flux qui récupère des données à partir d'une URL spécifiée à un intervalle donné, puis transmet les résultats au plug-in suivant.

Lit les données aux formats JSON, XML, CSV, TSV, TEXT et BLOB à partir des API HTTP/HTTPS dans des pipelines de traitement par flux.

Lit les données de HubSpot CRM dans des pipelines de traitement par flux.

Plug-in source par flux Kafka qui lit les événements d'Apache Kafka dans des pipelines de traitement par flux.

Ce plug-in vous permet de publier des alertes sur Kafka en tant qu'objets JSON.

Plug-in récepteur Kafka qui vous permet d'écrire des événements au format CSV ou JSON dans Kafka.

Ce plug-in récepteur écrit dans un sujet Pub/Sub dans des pipelines de traitement par flux.

Ce plug-in source lit les données depuis un abonnement Pub/Sub en temps réel.

Ce plug-in source effectue le suivi des mises à jour dans les objets sObject Salesforce. Les objets sObject peuvent être des opportunités, des contacts, des comptes, des prospects, tout objet personnalisé, etc.

Échantillonne les tweets en temps réel via un flux Spark. Les enregistrements de sortie utilisent ce schéma.

Le plug-in de fenêtrage est utilisé pour ouvrir une fenêtre dans un pipeline de traitement par flux.

La corbeille supprime tous les enregistrements d'entrée, ce qui signifie qu'aucune sortie n'est générée ni stockée.