Plug-in di Cloud Data Fusion

Questa origine legge l'intero contenuto di una tabella BigQuery.

Questo sink scrive in più tabelle BigQuery. I dati vengono prima scritti in una posizione temporanea su Cloud Storage, quindi caricati in BigQuery da lì.

Questo sink scrive in una tabella BigQuery. I dati vengono prima scritti in una posizione temporanea su Cloud Storage, quindi caricati in BigQuery da lì.

Questo plug-in origine legge gli oggetti da un percorso in un bucket Cloud Storage.

Questo plug-in sink scrive record in uno o più file di una directory su Cloud Storage in vari formati, come CSV, Avro, Parquet e JSON.

Legge da più tabelle all'interno di un database. Utilizzato con plug-in sink multipli come i sink multipli per Cloud Storage e i sink multipli per BigQuery per caricare i dati di tutto il database in un'unica pipeline.

Legge da un'istanza MySQL utilizzando una query SQL configurabile. Genera un singolo record per ogni riga restituita dalla query.

Legge da una tabella Oracle utilizzando una query SQL configurabile. Genera un singolo record per ogni riga restituita dalla query.

Questa origine legge sObject come opportunità, contatti, account, lead, oggetti personalizzati ecc. da Salesforce in modalità batch.

Si connette a un'origine SAP per l'estrazione di dati basata su batch e delta tramite Operational Data Provisioning (ODP).

Legge da un server SQL utilizzando una query SQL configurabile. Genera un singolo record per ogni riga restituita dalla query.

Questa origine legge l'intero contenuto di una tabella BigQuery.

Legge da una tabella BigQuery per recuperare gli argomenti da impostare nella pipeline.

Questo plug-in esegue una query SQL di BigQuery.

Questo sink scrive in più tabelle BigQuery. I dati vengono prima scritti in una posizione temporanea su Cloud Storage, quindi caricati in BigQuery da lì.

Questo sink scrive in una tabella BigQuery. I dati vengono prima scritti in una posizione temporanea su Cloud Storage, quindi caricati in BigQuery da lì.

Sink batch che scrive dati in Cloud Bigtable.

Questa origine legge i dati da Cloud Bigtable.

Importa i dati in uno qualsiasi degli asset supportati da Dataplex.

Legge i dati delle entità (tabelle) Dataplex che risiedono in asset Cloud Storage o BigQuery.

Questa origine legge i dati da Datastore. Datastore è un database di documenti NoSQL creato per scalabilità automatica e prestazioni elevate.

Questo sink scrive i dati in Cloud Datastore. Datastore è un database di documenti NoSQL creato per scalabilità automatica e prestazioni elevate.

Legge da Cloud Firestore in pipeline in modalità batch.

Plug-in per scrivere in Cloud Firestore in pipeline in modalità batch e flusso.

Questo plug-in sink scrive record in uno o più file di una directory su Cloud Storage in vari formati, come CSV, Avro, Parquet e JSON.

Questo plug-in origine legge gli oggetti da un percorso in un bucket Cloud Storage.

Legge un file Cloud Storage per recuperare gli argomenti da impostare nella pipeline.

Questo plug-in elimina gli oggetti in un bucket Cloud Storage.

Questo plug-in copia oggetti da un bucket Cloud Storage a un altro. È possibile copiare un singolo oggetto oppure una directory di oggetti.

Questo plug-in crea oggetti in un bucket Cloud Storage.

Crea un file DONE (o SUCCESS) vuoto nel bucket Cloud Storage specificato, al termine della pipeline oppure dopo l'esito positivo o negativo, per orchestrare i processi dipendenti.

Questo plug-in sposta oggetti da un bucket Cloud Storage a un altro. È possibile spostare un singolo oggetto oppure una directory di oggetti.

Questo plug-in viene utilizzato in combinazione con l'origine MultiTableDatabase per scrivere record da più database in directory separate.

Decripta i dati sensibili precedentemente criptati da Cloud Data Loss Prevention (DLP) utilizzando una trasformazione di crittografia reversibile, come la crittografia con protezione del formato (FPE).

Separa i record sensibili in base alla corrispondenza con un modello definito dall'utente utilizzando le API Cloud Data Loss Prevention (DLP).

Oscura i record sensibili utilizzando Cloud Data Loss Prevention (DLP), abbinando alcuni filtri DLP predefiniti o un modello personalizzato definito dall'utente.

Legge i file dalla directory di Google Drive specificata tramite l'API Google Drive.

Il plug-in sink salva i file dalla pipeline nella directory Google Drive tramite l'API Google Drive.

Scrive fogli di lavoro nella directory Google Drive specificata.

Legge i fogli di lavoro dalla directory di Google Drive specificata.

Questo sink scrive in un argomento Pub/Sub nelle pipeline in modalità flusso.

Questa origine legge in tempo reale da una sottoscrizione Pub/Sub.

Questo sink scrive in una tabella Cloud Spanner.

Questa origine legge da una tabella Cloud Spanner.

Questo plug-in converte i file audio in testo utilizzando Speech-to-Text.

Raggruppa per uno o più campi, poi esegue funzioni aggregate come avg, count, count(*), first, last, max, min, sum, collect su ciascun gruppo.

Unisce i record da uno o più input in base alle chiavi di unione. Supporta inner e outer join, la selezione e la ridenominazione dei campi di output.

Restituisce i primi "n" record del set di input in base ai criteri specificati nella configurazione del plug-in.

Applica le funzioni di aggregazione a una finestra di dati.

Invia un'email alla fine dell'esecuzione di una pipeline.

Azione per inviare un'email alla fine dell'esecuzione di una pipeline.

Crea un file DONE (o SUCCESS) vuoto nel bucket Cloud Storage specificato, al termine della pipeline oppure dopo l'esito positivo o negativo, per orchestrare i processi dipendenti.

Esegue una richiesta HTTP al termine dell'esecuzione di una pipeline.

Kafka Alert Publisher che consente di pubblicare avvisi in Kafka come oggetti JSON.

Esegue una query MariaDB al termine dell'esecuzione della pipeline. Può essere configurato per essere eseguito solo a operazione riuscita, solo in caso di errore oppure sempre al termine dell'esecuzione.

Esegue una query Netezza al termine dell'esecuzione della pipeline. Può essere configurato per essere eseguito solo a operazione riuscita, solo in caso di errore oppure sempre al termine dell'esecuzione.

Esegue una query Oracle al termine dell'esecuzione della pipeline. Può essere configurato per essere eseguito solo a operazione riuscita, solo in caso di errore oppure sempre al termine dell'esecuzione.

Esegue una query PostgreSQL al termine dell'esecuzione della pipeline. Può essere configurato per essere eseguito solo a operazione riuscita, solo in caso di errore oppure sempre al termine dell'esecuzione.

Esegue una query SQL Server al termine dell'esecuzione della pipeline. Può essere configurato per essere eseguito solo a operazione riuscita, solo in caso di errore oppure sempre al termine dell'esecuzione.

Esegue una query Teradata al termine dell'esecuzione della pipeline. Può essere configurato per essere eseguito solo a operazione riuscita, solo in caso di errore oppure sempre al termine dell'esecuzione.

Pubblica avvisi nel Transactional Messaging System (TMS) CDAP come oggetti JSON.

Sink batch che scrive dati in Apache Cassandra.

Origine in modalità batch che legge da Apache Cassandra.

Scrive record in una tabella HBase con una mappatura dei campi alla chiave di riga e tutti gli altri campi di record mappati ai qualificatori di colonna.

Origine in modalità batch che legge da una famiglia di colonne in una tabella HBase.

Hive Export prende la query selezionata come input per eseguirla nella tabella Hive e archivia i risultati nel percorso specificato.

Importa i dati da una directory/un file in una tabella Hive utilizzando l'istruzione Hive Load.

Azione per recuperare i dati da un endpoint HTTP esterno e creare un file in HDFS.

Kafka Alert Publisher che consente di pubblicare avvisi in Kafka come oggetti JSON.

Origine Kafka in modalità batch che legge gli eventi da Apache Kafka nelle pipeline in modalità batch.

Origine Kafka in modalità flusso che legge gli eventi da Apache Kafka nelle pipeline in modalità flusso.

Sink Kafka che consente di scrivere eventi in Kafka in formato CSV o JSON.

Plug-in CDAP per l'importazione di dati in Apache Kudu. Il plug-in può essere configurato per le pipeline in modalità batch e in tempo reale.

Plug-in CDAP per la lettura di dati da una tabella Apache Kudu.

Esegue il codice Spark fornito dall'utente in Python.

Questo plug-in esegue la ripartizione di un RDD Spark.

Esegue in Scala il codice Spark fornito dall'utente che trasforma un RDD in RDD, con accesso completo a tutte le funzionalità di Spark.

Esegue in Scala il codice Spark fornito dall'utente.

Esegue in Scala il codice Spark fornito dall'utente che opera su un RDD o un DataFrame di input, con accesso completo a tutte le funzionalità di Spark.

Analizza i log di qualsiasi origine di input per trovare informazioni pertinenti come URI, IP, browser, dispositivo, codice di stato HTTP e timestamp.

Plug-in origine per caricare dati da un modello Anaplan in una pipeline di dati.

Plug-in sink per supportare l'importazione di dati da CDAP nel server Anaplan.

Esegue un'azione/un processo predefiniti nel modello Anaplan specificato. Viene generalmente utilizzato per preparare l'importazione e l'esportazione dei dati.

Legge i dati pubblicitari dall'API Facebook Insights in pipeline in modalità batch.

Legge da GitHub in pipeline in modalità batch.

Legge tutti i report Google Ads da un account Google Ads in pipeline in modalità batch.

Legge il tipo di report specificato dagli account Google Ads in pipeline in modalità batch.

Legge da Google Analytics 360 in pipeline in modalità batch.

Legge da Google Analytics 360 in pipeline in modalità flusso.

Legge i file dalla directory di Google Drive specificata tramite l'API Google Drive.

Il plug-in sink salva i file dalla pipeline nella directory Google Drive tramite l'API Google Drive.

Legge da Google Search Console in pipeline in modalità batch.

Scrive fogli di lavoro nella directory Google Drive specificata.

Legge i fogli di lavoro dalla directory di Google Drive specificata.

Legge i dati nei formati JSON, XML, CSV, TSV, TEXT e BLOB dalle API HTTP/HTTPS in pipeline in modalità batch.

Plug-in sink per inviare messaggi dalla pipeline a un endpoint HTTP esterno.

Esegue una richiesta HTTP al termine dell'esecuzione di una pipeline.

Si tratta di un'origine in modalità flusso che recupera i dati da un URL specificato a un determinato intervallo e passa i risultati al plug-in successivo.

Legge i dati nei formati JSON, XML, CSV, TSV, TEXT e BLOB dalle API HTTP/HTTPS in pipeline in modalità flusso.

Azione per recuperare i dati da un endpoint HTTP esterno e creare un file in HDFS.

Plug-in per scrivere dati in HubSpot CRM in pipeline in modalità batch e flusso.

Legge i dati da HubSpot CRM in pipeline in modalità flusso.

Legge i dati da HubSpot CRM in pipeline in modalità batch.

Questa origine legge sObject come opportunità, contatti, account, lead, oggetti personalizzati ecc. da Salesforce in modalità batch.

Questa origine monitora gli aggiornamenti degli sObject Salesforce. Esempi di sObject sono opportunità, contatti, account, lead, oggetti personalizzati ecc.

Sink batch che inserisce sObject come opportunità, contatti, account, lead, oggetti personalizzati ecc. in Salesforce.

Questa origine monitora gli aggiornamenti degli sObject Salesforce, come opportunità, contatti, account, lead, oggetti personalizzati ecc.

Questo sink inserisce i record in un'estensione dati di Salesforce Marketing Cloud (SFMC) tramite integrazione tra server con l'API SFMC.

Questa origine legge più sObject da Salesforce. Da utilizzare insieme a più sink.

Legge da una o più tabelle all'interno di ServiceNow.

Questo plug-in converte i file audio in testo utilizzando Speech-to-Text.

Legge da Splunk in pipeline in modalità flusso.

Legge da Splunk in pipeline in modalità batch.

Legge oggetti come commenti agli articoli, commenti ai post, commenti alle richieste, commenti ai ticket, gruppi, organizzazioni, valutazioni della soddisfazione, tag, campi dei ticket, metriche dei ticket, eventi delle metriche dei ticket, ticket e utenti di Zendesk.

Lettura multi-origine di più oggetti da Zendesk che vengono poi indirizzati a destinazioni specifiche. Da utilizzare insieme a più sink.

Plug-in per scrivere dati in Zuora in pipeline in modalità batch e flusso.

Legge i dati da Zuora in pipeline in modalità batch.

Scrive in un file system in vari formati.

Questa origine viene utilizzata ogni volta che devi leggere da un file system distribuito.

Scrive record in uno o più file di una directory su Cloud Storage in vari formati, tra cui CSV, Avro, Parquet e JSON.

Questa origine viene utilizzata ogni volta che devi leggere da Amazon S3.

Questo sink viene utilizzato per scrivere in Amazon S3 in diversi formati.

L'azione Amazon S3 Client viene utilizzata per lavorare con bucket e oggetti S3 prima o dopo l'esecuzione di una pipeline.

Sink Kinesis che restituisce un flusso Amazon Kinesis specifico.

Origine Spark in modalità flusso che legge dai flussi di dati AWS Kinesis.

Il plug-in di azione Redshift to S3 esegue il comando UNLOAD su AWS per salvare i risultati di una query da Redshift in uno o più file su Amazon S3.

L'azione S3 to Redshift carica i dati dal bucket AWS S3 nella tabella AWS Redshift.

Deduplica i record utilizzando uno o più campi o l'intero record. Inoltre, supporta la scelta logica di un record tra i record duplicati in base a un campo del filtro. Le funzioni logiche supportate sono max, min, first e last.

Deduplica i record di input in modo che tutti i record di output siano distinti.

Esclude i messaggi in base a un criterio di filtro specificato.

Separa i record sensibili in base alla corrispondenza con un modello definito dall'utente utilizzando le API Cloud Data Loss Prevention (DLP).

Questo plug-in applica istruzioni sulla trasformazione dei dati generate tramite un'interfaccia utente interattiva o manualmente nei record dei dati.

Questa origine viene utilizzata ogni volta che devi leggere da Amazon S3.

Origine in modalità batch per utilizzare Azure Blob Storage di Microsoft come origine.

Il plug-in di azione Azure Decompress decomprime i file gz da un container sul servizio Azure Blob Storage in un altro container.

Carica i dati da file temporanei esterni o interni su Cloud Storage in una tabella Snowflake esistente.

Questo plug-in sink scrive record in uno o più file di una directory su Cloud Storage in vari formati, come CSV, Avro, Parquet e JSON.

Questo plug-in legge gli oggetti da un percorso di un bucket Cloud Storage.

Legge un file Cloud Storage per recuperare gli argomenti da impostare nella pipeline.

Questo plug-in elimina gli oggetti in un bucket Cloud Storage.

Questo plug-in copia oggetti da un bucket Cloud Storage a un altro. È possibile copiare un singolo oggetto oppure una directory di oggetti.

Questo plug-in crea oggetti in un bucket Cloud Storage.

Questo plug-in sposta oggetti da un bucket Cloud Storage a un altro. È possibile spostare un singolo oggetto oppure una directory di oggetti.

Questo plug-in viene utilizzato in combinazione con l'origine MultiTableDatabase per scrivere record da più database in directory separate.

Crea un file DONE (o SUCCESS) vuoto nel bucket Cloud Storage specificato, al termine della pipeline oppure dopo l'esito positivo o negativo, per orchestrare i processi dipendenti.

Il plug-in di azione Azure Delete elimina un container sul servizio Azure Storage Blob.

Esegue l'unload dei dati da una tabella Snowflake a una località di Cloud Storage interna o esterna (archiviazione in un'area intermedia).

Esegue codice JavaScript fornito dall'utente che trasforma un record in zero o più record.

Esegue il codice Spark fornito dall'utente in Python.

Esegue il codice Python fornito dall'utente per la trasformazione dei record di input, che sono disponibili come dizionario Python.

Esegue in Scala il codice Spark fornito dall'utente che trasforma un RDD in RDD, con accesso completo a tutte le funzionalità di Spark.

Esegue in Scala il codice Spark fornito dall'utente.

Esegue in Scala il codice Spark fornito dall'utente che opera su un RDD o un DataFrame di input, con accesso completo a tutte le funzionalità di Spark.

Comprime i campi configurati utilizzando diversi algoritmi di compressione, come SNAPPY, ZIP e GZIP.

L'azione Decompress viene utilizzata per espandere i file archiviati o compressi (.zip, .gz, .tar.gz ecc.) prima di elaborarli ulteriormente in una pipeline.

Decomprime i campi configurati utilizzando algoritmi di compressione, come SNAPPY, ZIP e GZIP.

Plug-in per il flusso di controllo che consente l'esecuzione condizionale all'interno delle pipeline in base alle espressioni.

Raccoglie gli errori emessi dalla fase precedente e aggiunge codice, messaggio di errore e fase al record.

Sink in modalità batch che provoca l'errore della pipeline subito dopo la ricezione del primo record.

Questo plug-in invia i record con un valore null per un determinato campo alla porta null e quelli con un valore diverso da null alla porta per i valori non-null.

Instrada un record a una porta appropriata in base alla valutazione di un'espressione sul valore di uno o più dei suoi campi.

Union Splitter viene utilizzato per suddividere i dati in base a uno schema di unione, in modo che la logica specifica per il tipo possa essere eseguita a valle.

Esegue un'azione/un processo predefiniti nel modello Anaplan specificato. Viene generalmente utilizzato per preparare l'importazione e l'esportazione dei dati.

Esegue una query SQL all'inizio o alla fine di una pipeline.

Azione che esegue un comando di database.

Esegue una query del database al termine dell'esecuzione della pipeline. Può essere configurato per essere eseguito solo a operazione riuscita, solo in caso di errore oppure sempre al termine dell'esecuzione.

Azione che esegue un comando DB2.

L'azione Decompress viene utilizzata per espandere i file archiviati o compressi (.zip, .gz, .tar.gz ecc.) prima di elaborarli ulteriormente in una pipeline.

Questo plug-in di azione può essere utilizzato per verificare se un file è vuoto o se i contenuti di un file corrispondono a un determinato pattern.

Elimina uno o più file.

Sposta uno o più file.

Copia file dal server FTP nella destinazione specificata.

Copia file al server FTP da una destinazione specificata.

Questo plug-in elimina gli oggetti in un bucket Cloud Storage.

Questo plug-in copia oggetti da un bucket Cloud Storage a un altro. È possibile copiare un singolo oggetto oppure una directory di oggetti.

Questo plug-in crea oggetti in un bucket Cloud Storage.

Questo plug-in sposta oggetti da un bucket Cloud Storage a un altro. È possibile spostare un singolo oggetto oppure una directory di oggetti.

Azione per recuperare i dati da un endpoint HTTP esterno e creare un file in HDFS.

Azione che esegue un comando MariaDB.

Azione che esegue un comando MySQL.

Azione che esegue un comando Netezza.

Azione che esegue un comando Oracle.

Plug-in di azione per esportare in modo efficiente i dati da Oracle a un file system utilizzando gli strumenti a riga di comando di Oracle.

Azione che esegue un comando PostgreSQL.

Il plug-in di azione Redshift to S3 esegue il comando UNLOAD su AWS per salvare i risultati di una query da Redshift in uno o più file su Amazon S3.

Stabilisce una connessione SSH con macchina remota per eseguire il comando su quella macchina.

L'azione S3 to Redshift carica i dati dal bucket AWS S3 nella tabella AWS Redshift.

SFTP Copy consente di copiare i file dalla directory specificata sui server SFTP alla destinazione indicata.

Plug-in di azione CDAP per eliminare i file specificati da un server SFTP.

SFTP Put consente di caricare uno o più file da un file system (locale/HDFS) a un server FTP. Inoltre, possono essere utilizzate le espressioni regolari per filtrare solo i file che ti interessano.

Esegue una query SQL specificata in Snowflake.

Azione che esegue un comando SQL Server.

Azione che esegue un comando Teradata.

Copia uno o più file su una condivisione Microsoft Windows in un file system.

Plug-in per scrivere dati in HubSpot CRM in pipeline in modalità batch e flusso.

Legge i dati da HubSpot CRM in pipeline in modalità flusso.

Legge i dati da HubSpot CRM in pipeline in modalità batch.

Questa origine legge sObject come opportunità, contatti, account, lead, oggetti personalizzati ecc. da Salesforce in modalità batch.

Sink batch che inserisce sObject come opportunità, contatti, account, lead, oggetti personalizzati ecc. in Salesforce.

Questa origine monitora gli aggiornamenti degli sObject Salesforce. Esempi di sObject sono opportunità, contatti, account, lead, oggetti personalizzati ecc.

Questa origine monitora gli aggiornamenti degli sObject Salesforce, come opportunità, contatti, account, lead, oggetti personalizzati ecc.

Questo sink inserisce i record in un'estensione dati di Salesforce Marketing Cloud (SFMC) tramite integrazione tra server con l'API SFMC.

Questa origine legge più sObject da Salesforce. Da utilizzare insieme a più sink.

Formatta gli input in un record CSV utilizzando formati come DELIMITED, EXCEL, MYSQL, RFC4180 e TDF.

Analizza un record CSV formattato come DEFAULT, EXCEL, MYSQL, RFC4180, delimitato da tabulazioni o delimitato da barre verticali in un record strutturato.

Scrive in un file system in vari formati.

Questa origine viene utilizzata ogni volta che devi leggere da un file system distribuito.

Questo plug-in sink scrive record in uno o più file di una directory su Cloud Storage in vari formati, come CSV, Avro, Parquet e JSON.

Sink Kafka che consente di scrivere eventi in Kafka in formato CSV o JSON.

Sink batch che scrive dati in Cloud Bigtable.

Questa origine legge i dati da Cloud Bigtable.

Azione che esegue un comando di database.

Legge da un database utilizzando una query SQL configurabile. Genera un singolo record per ogni riga restituita dalla query.

Scrive i record nella tabella di un database. Ogni record viene scritto in una riga della tabella.

Legge dalla tabella di un database relazionale per recuperare gli argomenti da impostare nella pipeline.

Esegue una query del database al termine dell'esecuzione della pipeline. Può essere configurato per essere eseguito solo a operazione riuscita, solo in caso di errore oppure sempre al termine dell'esecuzione.

Legge da un database DB2 utilizzando una query SQL configurabile. Genera un singolo record per ogni riga restituita dalla query.

Esegue una query DB2 al termine dell'esecuzione della pipeline. Può essere configurato per essere eseguito solo a operazione riuscita, solo in caso di errore oppure sempre al termine dell'esecuzione.

Azione che esegue un comando DB2.

Scrive i record in una tabella DB2. Ogni record viene scritto in una riga della tabella.

Scrive i record in una tabella MariaDB. Ogni record viene scritto in una riga della tabella.

Legge da un database MariaDB utilizzando una query SQL configurabile. Genera un singolo record per ogni riga restituita dalla query.

Esegue una query MariaDB al termine dell'esecuzione della pipeline. Può essere configurato per essere eseguito solo a operazione riuscita, solo in caso di errore oppure sempre al termine dell'esecuzione.

Azione che esegue un comando MariaDB.

Legge da più tabelle all'interno di un database. Utilizzato con plug-in sink multipli come i sink multipli per Cloud Storage e BigQuery, per caricare i dati di un intero database in un'unica pipeline.

Esegue una query MySQL al termine dell'esecuzione della pipeline. Può essere configurato per essere eseguito solo a operazione riuscita, solo in caso di errore oppure sempre al termine dell'esecuzione.

Scrive i record in una tabella MySQL. Ogni record viene scritto in una riga della tabella.

Legge da un'istanza MySQL utilizzando una query SQL configurabile. Genera un singolo record per ogni riga restituita dalla query.

Azione che esegue un comando MySQL.

Legge da una tabella Oracle utilizzando una query SQL configurabile. Genera un singolo record per ogni riga restituita dalla query.

Scrive i record in una tabella Oracle. Ogni record viene scritto in una riga della tabella.

Esegue una query Oracle al termine dell'esecuzione della pipeline. Può essere configurato per essere eseguito solo a operazione riuscita, solo in caso di errore oppure sempre al termine dell'esecuzione.

Azione che esegue un comando Oracle.

Plug-in di azione per esportare in modo efficiente i dati da Oracle a un file system utilizzando gli strumenti a riga di comando di Oracle.

Legge da un database PostgreSQL utilizzando una query SQL configurabile. Genera un singolo record per ogni riga restituita dalla query.

Scrive i record in una tabella PostgreSQL. Ogni record viene scritto in una riga della tabella.

Esegue una query PostgreSQL al termine dell'esecuzione della pipeline. Può essere configurato per essere eseguito solo a operazione riuscita, solo in caso di errore oppure sempre al termine dell'esecuzione.

Azione che esegue un comando PostgreSQL.

Questo sink scrive in una tabella Cloud Spanner.

Questa origine legge da una tabella Cloud Spanner.

Scrive i record in una tabella SQL Server. Ogni record viene scritto in una riga della tabella.

Esegue una query SQL Server al termine dell'esecuzione della pipeline. Può essere configurato per essere eseguito solo a operazione riuscita, solo in caso di errore oppure sempre al termine dell'esecuzione.

Legge da un server SQL utilizzando una query SQL configurabile. Genera un singolo record per ogni riga restituita dalla query.

Azione che esegue un comando SQL Server.

DB2 esegue una query DB2 al termine dell'esecuzione della pipeline. Può essere configurato per essere eseguito solo a operazione riuscita, solo in caso di errore oppure sempre al termine dell'esecuzione.

Questa origine legge l'intero contenuto di una tabella BigQuery.

Legge da una tabella BigQuery per recuperare gli argomenti da impostare nella pipeline.

Questo plug-in esegue una query SQL di BigQuery.

Questo sink scrive in più tabelle BigQuery. I dati vengono prima scritti in una posizione temporanea su Cloud Storage, quindi caricati in BigQuery da lì.

Questo sink scrive in una tabella BigQuery. I dati vengono prima scritti in una posizione temporanea su Cloud Storage, quindi caricati in BigQuery da lì.

Carica i dati da file temporanei esterni o interni su Cloud Storage in una tabella Snowflake esistente.

Hive Export prende la query selezionata come input per eseguirla nella tabella Hive e archivia i risultati nel percorso specificato.

Importa i dati da una directory/un file in una tabella Hive utilizzando l'istruzione Hive Load.

Scrive i record in una tabella Netezza. Ogni record viene scritto in una riga della tabella.

Legge da un database Netezza utilizzando una query SQL configurabile. Genera un singolo record per ogni riga restituita dalla query.

Esegue una query Netezza al termine dell'esecuzione della pipeline. Può essere configurato per essere eseguito solo a operazione riuscita, solo in caso di errore oppure sempre al termine dell'esecuzione.

Azione che esegue un comando Netezza.

Il plug-in di azione Redshift to S3 esegue il comando UNLOAD su AWS per salvare i risultati di una query da Redshift in uno o più file su Amazon S3.

L'azione S3 to Redshift carica i dati dal bucket AWS S3 nella tabella AWS Redshift.

Crea una rappresentazione SCD2 di un record raggruppando i record di origine in base alla chiave specificata e generando le relative date di inizio e di fine (scadenza).

Scrive i dati in una tabella Snowflake nelle pipeline in modalità batch.

Legge i dati delle tabelle Snowflake nelle pipeline in modalità batch.

Esegue una query SQL specificata in Snowflake.

Esegue l'unload dei dati da una tabella Snowflake a una località di Cloud Storage interna o esterna (archiviazione in un'area intermedia).

Scrive i record in una tabella Teradata. Ogni record viene scritto in una riga della tabella.

Legge da un database Teradata utilizzando una query SQL configurabile. Genera un singolo record per ogni riga restituita dalla query.

Esegue una query Teradata al termine dell'esecuzione della pipeline. Può essere configurato per essere eseguito solo a operazione riuscita, solo in caso di errore oppure sempre al termine dell'esecuzione.

Azione che esegue un comando Teradata.

Esegue esportazioni collettive dei dati di una tabella Vertica in un file.

Il plug-in di azione Vertica Bulk Import legge tutti i file di una determinata directory e importa collettivamente i contenuti in una tabella Vertica.

Decripta i dati sensibili precedentemente criptati da Cloud Data Loss Prevention (DLP) utilizzando una trasformazione di crittografia reversibile, come la crittografia con protezione del formato (FPE).

Separa i record sensibili in base alla corrispondenza con un modello definito dall'utente utilizzando le API Cloud Data Loss Prevention (DLP).

Oscura i record sensibili utilizzando Cloud Data Loss Prevention (DLP), abbinando alcuni filtri DLP predefiniti o un modello personalizzato definito dall'utente.

Esegue una richiesta HTTP per recuperare gli argomenti da impostare nella pipeline.

Legge dalla tabella di un database relazionale per recuperare gli argomenti da impostare nella pipeline.

Legge un file Cloud Storage per recuperare gli argomenti da impostare nella pipeline.

Invia un'email alla fine dell'esecuzione di una pipeline.

Azione per inviare un'email alla fine dell'esecuzione di una pipeline.

Legge i dati relativi a campagne di marketing esistenti, analisi delle email, rimbalzi e segnalazioni di spam da SendGrid.

Scrive i dati in SendGrid in pipeline in modalità batch e flusso.

Formatta gli input in un record CSV utilizzando formati come DELIMITED, EXCEL, MYSQL, RFC4180 e TDF.

Analizza un record CSV formattato come DEFAULT, EXCEL, MYSQL, RFC4180, delimitato da tabulazioni o delimitato da barre verticali in un record strutturato.

Scrive in un file system in vari formati.

Questa origine viene utilizzata ogni volta che devi leggere da un file system distribuito.

Origine di flussi di file che monitora una directory e trasmette i contenuti di tutti i nuovi file che vi vengono aggiunti.

Questo plug-in sink esegue aggiunte a un file esistente fino a quando non raggiunge una certa soglia di dimensione o età.

Questo plug-in di azione può essere utilizzato per verificare se un file è vuoto o se i contenuti di un file corrispondono a un determinato pattern.

Elimina uno o più file.

Sposta uno o più file.

Origine in modalità batch per leggere da FTP (ftp://…) o SFTP (sftp://…).

Copia file dal server FTP nella destinazione specificata.

Copia file al server FTP da una destinazione specificata.

Questa trasformazione sfrutta la libreria Apache PDFBox per estrarre testo e metadati da un file PDF.

Il plug-in di azione Redshift to S3 esegue il comando UNLOAD su AWS per salvare i risultati di una query da Redshift in uno o più file su Amazon S3.

Questo sink viene utilizzato per scrivere in Amazon S3 in diversi formati.

L'azione S3 to Redshift carica i dati dal bucket AWS S3 nella tabella AWS Redshift.

SFTP Copy consente di copiare i file dalla directory specificata sui server SFTP alla destinazione indicata.

Plug-in di azione CDAP per eliminare i file specificati da un server SFTP.

SFTP Put consente di caricare uno o più file da un file system (locale/HDFS) a un server FTP. Inoltre, possono essere utilizzate le espressioni regolari per filtrare solo i file che ti interessano.

Deduplica i record utilizzando uno o più campi o l'intero record. Inoltre, supporta la scelta logica di un record tra i record duplicati in base a un campo del filtro. Le funzioni logiche supportate sono max, min, first e last.

Deduplica i record di input in modo che tutti i record di output siano distinti.

Esclude i messaggi in base a un criterio di filtro specificato.

Separa i record sensibili in base alla corrispondenza con un modello definito dall'utente utilizzando le API Cloud Data Loss Prevention (DLP).

Questo plug-in invia i record con un valore null per un determinato campo alla porta null e quelli con un valore diverso da null alla porta per i valori non-null.

Campiona set di dati di grandi dimensioni che vengono trasmessi attraverso questo plug-in per estrarre record casuali utilizzando il campionamento sistematico o di tipo reservoir.

Restituisce i primi "n" record del set di input in base ai criteri specificati nella configurazione del plug-in.

Origine in modalità batch per leggere da FTP (ftp://…) o SFTP (sftp://…).

Copia file dal server FTP nella destinazione specificata.

Copia file al server FTP da una destinazione specificata.

SFTP Copy consente di copiare i file dalla directory specificata sui server SFTP alla destinazione indicata.

Plug-in di azione CDAP per eliminare i file specificati da un server SFTP.

SFTP Put consente di caricare uno o più file da un file system (locale/HDFS) a un server FTP. Inoltre, possono essere utilizzate le espressioni regolari per filtrare solo i file che ti interessano.

Legge tutti i report Google Ads da un account Google Ads in pipeline in modalità batch.

Legge il tipo di report specificato dagli account Google Ads in pipeline in modalità batch.

Legge da Google Search Console in pipeline in modalità batch.

Legge da Google Analytics 360 in pipeline in modalità batch.

Legge da Google Analytics 360 in pipeline in modalità flusso.

Legge i file dalla directory di Google Drive specificata tramite l'API Google Drive.

Il plug-in sink salva i file dalla pipeline nella directory Google Drive tramite l'API Google Drive.

Legge i fogli di lavoro dalla directory di Google Drive specificata.

Scrive fogli di lavoro nella directory Google Drive specificata.

Scrive record in una tabella HBase con una mappatura dei campi alla chiave di riga e tutti gli altri campi di record mappati ai qualificatori di colonna.

Origine in modalità batch che legge da una famiglia di colonne in una tabella HBase.

Hive Export prende la query selezionata come input per eseguirla nella tabella Hive e archivia i risultati nel percorso specificato.

Importa i dati da una directory/un file in una tabella Hive utilizzando l'istruzione Hive Load.

Azione per recuperare i dati da un endpoint HTTP esterno e creare un file in HDFS.

Il plug-in XML Reader è un plug-in origine che consente agli utenti di leggere i file XML archiviati su HDFS.

Azione per recuperare i dati da un endpoint HTTP esterno e creare un file in HDFS.

Esegue esportazioni collettive dei dati di una tabella Vertica in un file.

Il plug-in di azione Vertica Bulk Import legge tutti i file di una determinata directory e importa collettivamente i contenuti in una tabella Vertica.

Esegue una richiesta HTTP per recuperare gli argomenti da impostare nella pipeline.

Legge da un database DB2 utilizzando una query SQL configurabile. Genera un singolo record per ogni riga restituita dalla query.

Esegue una query DB2 al termine dell'esecuzione della pipeline. Può essere configurato per essere eseguito solo a operazione riuscita, solo in caso di errore oppure sempre al termine dell'esecuzione.

Azione che esegue un comando DB2.

Scrive i record in una tabella DB2. Ogni record viene scritto in una riga della tabella.

Scrive i record in una tabella Netezza. Ogni record viene scritto in una riga della tabella.

Legge da un database Netezza utilizzando una query SQL configurabile. Genera un singolo record per ogni riga restituita dalla query.

Esegue una query Netezza al termine dell'esecuzione della pipeline. Può essere configurato per essere eseguito solo a operazione riuscita, solo in caso di errore oppure sempre al termine dell'esecuzione.

Azione che esegue un comando Netezza.

Legge da un database utilizzando una query SQL configurabile. Genera un singolo record per ogni riga restituita dalla query.

Scrive i record nella tabella di un database. Ogni record viene scritto in una riga della tabella.

Legge i documenti di una raccolta MongoDB e converte ogni documento in uno StructuredRecord con l'aiuto di uno schema specificato.

Questo sink scrive su una raccolta MongoDB.

Esegue una query MySQL al termine dell'esecuzione della pipeline. Può essere configurato per essere eseguito solo a operazione riuscita, solo in caso di errore oppure sempre al termine dell'esecuzione.

Scrive i record in una tabella MySQL. Ogni record viene scritto in una riga della tabella.

Legge da un'istanza MySQL utilizzando una query SQL configurabile. Genera un singolo record per ogni riga restituita dalla query.

Azione che esegue un comando MySQL.

Scrive i record in una tabella Netezza. Ogni record viene scritto in una riga della tabella.

Legge da un database Netezza utilizzando una query SQL configurabile. Genera un singolo record per ogni riga restituita dalla query.

Esegue una query Netezza al termine dell'esecuzione della pipeline. Può essere configurato per essere eseguito solo a operazione riuscita, solo in caso di errore oppure sempre al termine dell'esecuzione.

Azione che esegue un comando Netezza.

Legge da una tabella Oracle utilizzando una query SQL configurabile. Genera un singolo record per ogni riga restituita dalla query.

Scrive i record in una tabella Oracle. Ogni record viene scritto in una riga della tabella.

Esegue una query Oracle al termine dell'esecuzione della pipeline. Può essere configurato per essere eseguito solo a operazione riuscita, solo in caso di errore oppure sempre al termine dell'esecuzione.

Azione che esegue un comando Oracle.

Plug-in di azione per esportare in modo efficiente i dati da Oracle a un file system utilizzando gli strumenti a riga di comando di Oracle.

Legge da un database PostgreSQL utilizzando una query SQL configurabile. Genera un singolo record per ogni riga restituita dalla query.

Scrive i record in una tabella PostgreSQL. Ogni record viene scritto in una riga della tabella.

Esegue una query PostgreSQL al termine dell'esecuzione della pipeline. Può essere configurato per essere eseguito solo a operazione riuscita, solo in caso di errore oppure sempre al termine dell'esecuzione.

Azione che esegue un comando PostgreSQL.

Scrive i record in una tabella SQL Server. Ogni record viene scritto in una riga della tabella.

Esegue una query SQL Server al termine dell'esecuzione della pipeline. Può essere configurato per essere eseguito solo a operazione riuscita, solo in caso di errore oppure sempre al termine dell'esecuzione.

Legge da un server SQL utilizzando una query SQL configurabile. Genera un singolo record per ogni riga restituita dalla query.

Azione che esegue un comando SQL Server.

Scrive i record in una tabella Teradata. Ogni record viene scritto in una riga della tabella.

Legge da un database Teradata utilizzando una query SQL configurabile. Genera un singolo record per ogni riga restituita dalla query.

Esegue una query Teradata al termine dell'esecuzione della pipeline. Può essere configurato per essere eseguito solo a operazione riuscita, solo in caso di errore oppure sempre al termine dell'esecuzione.

Azione che esegue un comando Teradata.

Scrive dati in Elasticsearch come stringa JSON e li indicizza utilizzando l'indice, il tipo e l'idField specificati dall'utente.

Scrive record in uno o più file di una directory su Cloud Storage in vari formati, come CSV, Avro, Parquet e JSON.

Formatta un record strutturato come oggetto JSON.

Analizza un evento JSON di input in un record utilizzando i percorsi JSON per estrarre campi da JSON di input nidificati complessi.

Sink Kafka che consente di scrivere eventi in Kafka in formato CSV o JSON.

Accetta un campo che contiene una stringa XML correttamente formattata e restituisce una versione della stringa JSON dei dati correttamente formattata.

Legge da Confluent Kafka in pipeline in modalità flusso.

Plug-in per scrivere su Confluent Kafka in pipeline in modalità flusso.

Origine Kafka in modalità batch che legge gli eventi da Apache Kafka nelle pipeline in modalità batch.

Origine Kafka in modalità flusso che legge gli eventi da Apache Kafka nelle pipeline in modalità flusso.

Kafka Alert Publisher che consente di pubblicare avvisi in Kafka come oggetti JSON.

Sink Kafka che consente di scrivere eventi in Kafka in formato CSV o JSON.

Legge da Splunk in pipeline in modalità batch.

Legge da Splunk in pipeline in modalità flusso.

Analizza i log di qualsiasi origine di input per trovare informazioni pertinenti come URI, IP, browser, dispositivo, codice di stato HTTP e timestamp.

Aggiunge un nuovo campo a ogni record. Il valore del campo può essere un nuovo UUID oppure può essere impostato direttamente tramite configurazione.

Crea una copia di ogni record di input ricevuto per un numero di volte configurato nell'output.

Plug-in per generare strutture gerarchiche da schemi piatti.

Questa trasformazione prende una data in un timestamp Unix o in una stringa e la converte in una stringa formattata (con macro).

Oscura i record sensibili utilizzando Cloud Data Loss Prevention (DLP), abbinando alcuni filtri DLP predefiniti o un modello personalizzato definito dall'utente.

Esegue la ricerca di un determinato campo all'interno di un set di dati di ricerca abbinandolo al set di dati di input e include il campo e il relativo valore nel set di dati risultante.

La trasformazione Multi Field Adder consente di aggiungere uno o più campi all'output.

Trasforma le funzionalità di input in n-grammi.

La trasformazione Projection consente di rilasciare, mantenere, rinominare e trasmettere i campi a un tipo diverso.

Dati un campo e un delimitatore, emette un record per ogni suddivisione del campo.

Converte i dati non elaborati in dati denormalizzati in base a una colonna chiave.

Crea una rappresentazione SCD2 di un record raggruppando i record di origine in base alla chiave specificata e generando le relative date di inizio e di fine (scadenza).

Normalizza i dati convertendo le colonne in righe.

Value Mapper è un plug-in per la trasformazione che mappa i valori stringa di un campo nel record di input a un valore di mappatura utilizzando un set di dati di mappatura.

Questo plug-in applica istruzioni sulla trasformazione dei dati generate tramite un'interfaccia utente interattiva o manualmente nei record dei dati.

Decodifica i campi configurati utilizzando metodi di decodifica come STRING_BASE64, BASE64, BASE32, STRING_BASE32 ed HEX.

Decripta uno o più campi in record di input utilizzando un archivio chiavi che deve essere presente su tutti i nodi del cluster.

Cripta uno o più campi in record di input utilizzando un archivio chiavi Java che deve essere presente su tutti i nodi del cluster.

Codifica i campi configurati utilizzando metodi di codifica come STRING_BASE64, BASE64, BASE32, STRING_BASE32 ed HEX.

Codifica i valori dei campi utilizzando algoritmi digest come MD2, MD5, SHA1, SHA256, SHA384 e SHA512.

Il plug-in Excel permette all'utente di leggere i dati di uno o più file Excel.

Copia uno o più file su una condivisione Microsoft Windows in un file system.

Scrive i dati nella directory Azure Data Lake Store in formato avro, orc o testuale.

Questo sink scrive su più directory di Azure Data Lake.

Elimina uno o più file all'interno del file system ADLS.

Origine in modalità batch per utilizzare Azure Blob Storage di Microsoft come origine.

L'origine in modalità batch Azure Data Lake Store legge i dati dai file Azure Data Lake Store e li converte in StructuredRecord.

Il plug-in di azione Azure Decompress decomprime i file gz da un container sul servizio Azure Blob Storage in un altro container.

Questa trasformazione sfrutta le API Azure Cognitive per estrarre volti e altri metadati, incluse le emozioni, da un insieme di immagini.

Il plug-in di azione Azure Delete elimina un container sul servizio Azure Storage Blob.

Esegue una query SQL Server al termine dell'esecuzione della pipeline. Può essere configurato per essere eseguito solo a operazione riuscita, solo in caso di errore oppure sempre al termine dell'esecuzione.

Legge da un server SQL utilizzando una query SQL configurabile. Genera un singolo record per ogni riga restituita dalla query.

Scrive i record in una tabella SQL Server. Ogni record viene scritto in una riga della tabella.

Azione che esegue un comando SQL Server.

Plug-in per la trasformazione di dati nidificati in dati flat.

Sink batch che scrive dati in Apache Cassandra.

Origine in modalità batch che legge da Apache Cassandra.

Questa origine legge i dati da Datastore. Datastore è un database di documenti NoSQL creato per scalabilità automatica e prestazioni elevate.

Questo sink scrive i dati in Cloud Datastore. Datastore è un database di documenti NoSQL creato per scalabilità automatica e prestazioni elevate.

Legge da Cloud Firestore in pipeline in modalità batch.

Plug-in per scrivere in Cloud Firestore in pipeline in modalità batch e flusso.

Scrive record in una tabella HBase con una mappatura dei campi alla chiave di riga e tutti gli altri campi di record mappati ai qualificatori di colonna.

Origine in modalità batch che legge da una famiglia di colonne in una tabella HBase.

Legge i documenti di una raccolta MongoDB e converte ogni documento in uno StructuredRecord con l'aiuto di uno schema specificato.

Questo sink scrive su una raccolta MongoDB.

Legge da una tabella Oracle utilizzando una query SQL configurabile. Genera un singolo record per ogni riga restituita dalla query.

Scrive i record in una tabella Oracle. Ogni record viene scritto in una riga della tabella.

Esegue una query Oracle al termine dell'esecuzione della pipeline. Può essere configurato per essere eseguito solo a operazione riuscita, solo in caso di errore oppure sempre al termine dell'esecuzione.

Azione che esegue un comando Oracle.

Plug-in di azione per esportare in modo efficiente i dati da Oracle a un file system utilizzando gli strumenti a riga di comando di Oracle.

Scrive in un file system in vari formati.

Questa origine viene utilizzata ogni volta che devi leggere da un file system distribuito.

Scrive record in uno o più file di una directory su Cloud Storage in vari formati, tra cui CSV, Avro, Parquet e JSON.

Esegue il codice Spark fornito dall'utente in Python.

Esegue il codice Python fornito dall'utente per la trasformazione dei record di input, che sono disponibili come dizionario Python.

Questa origine viene utilizzata ogni volta che devi leggere da Amazon S3.

Accelera la funzionalità SAP Table Batch Source per il processo Order to Cash.

Accelera la funzionalità SAP Table Batch Source per il processo Procure-to-Pay.

Si connette a un'origine SAP Ariba per integrazioni di dati batch in Google Cloud.

Si connette a un'origine SAP per l'estrazione di dati basata su batch e delta tramite il servizio BW Open Hub.

Si connette a un'origine SAP per l'estrazione di dati basata su batch utilizzando il protocollo Open Data Protocol (OData).

Si connette a un'origine SAP per l'estrazione di dati basata su batch e delta tramite Operational Data Provisioning (ODP).

Si connette a un'origine SAP per replicare i dati in Google Cloud utilizzando SAP Landscape Transformation (SLT).

Si connette a un'origine SAP per l'estrazione di dati basata su batch.

Si connette a un'origine SAP per trasferimenti di dati collettivi da tabelle e viste SAP.

Plug-in origine per caricare dati da un modello Anaplan in una pipeline di dati.

Plug-in sink per supportare l'importazione di dati da CDAP nel server Anaplan.

Esegue un'azione/un processo predefiniti nel modello Anaplan specificato. Viene generalmente utilizzato per preparare l'importazione e l'esportazione dei dati.

Plug-in per scrivere dati in HubSpot CRM in pipeline in modalità batch e flusso.

Legge i dati da HubSpot CRM in pipeline in modalità flusso.

Legge i dati da HubSpot CRM in pipeline in modalità batch.

Questa origine legge sObject come opportunità, contatti, account, lead, oggetti personalizzati ecc. da Salesforce in modalità batch.

Sink batch che inserisce sObject come opportunità, contatti, account, lead, oggetti personalizzati ecc. in Salesforce.

Questa origine monitora gli aggiornamenti degli sObject Salesforce, come opportunità, contatti, account, lead, oggetti personalizzati ecc.

Questo sink inserisce i record in un'estensione dati di Salesforce Marketing Cloud (SFMC) tramite integrazione tra server con l'API SFMC.

Questa origine legge più sObject da Salesforce. Da utilizzare insieme a più sink.

Legge da una o più tabelle all'interno di ServiceNow.

Legge oggetti come commenti agli articoli, commenti ai post, commenti alle richieste, commenti ai ticket, gruppi, organizzazioni, valutazioni della soddisfazione, tag, campi dei ticket, metriche dei ticket, eventi delle metriche dei ticket, ticket e utenti di Zendesk.

Lettura multi-origine di più oggetti da Zendesk che vengono poi indirizzati a destinazioni specifiche. Da utilizzare insieme a più sink.

Plug-in per scrivere dati in Zuora in pipeline in modalità batch e flusso.

Legge i dati da Zuora in pipeline in modalità batch.

Estrae documenti da Elasticsearch in base alla query specificata dall'utente.

Scrive dati in Elasticsearch come stringa JSON e li indicizza utilizzando l'indice, il tipo e l'idField specificati dall'utente.

Legge da Google Search Console in pipeline in modalità batch.

Carica i dati da file temporanei esterni o interni su Cloud Storage in una tabella Snowflake esistente.

Scrive i dati in una tabella Snowflake nelle pipeline in modalità batch.

Legge i dati delle tabelle Snowflake nelle pipeline in modalità batch.

Esegue una query SQL specificata in Snowflake.

Esegue l'unload dei dati da una tabella Snowflake a una località di Cloud Storage interna o esterna (archiviazione in un'area intermedia).

Analizza i log di qualsiasi origine di input per trovare informazioni pertinenti come URI, IP, browser, dispositivo, codice di stato HTTP e timestamp.

Esegue il codice Spark fornito dall'utente in Python.

Questo plug-in esegue la ripartizione di un RDD Spark.

Esegue in Scala il codice Spark fornito dall'utente che trasforma un RDD in RDD, con accesso completo a tutte le funzionalità di Spark.

Esegue in Scala il codice Spark fornito dall'utente.

Esegue in Scala il codice Spark fornito dall'utente che opera su un RDD o un DataFrame di input, con accesso completo a tutte le funzionalità di Spark.

Stabilisce una connessione SSH con macchina remota per eseguire il comando su quella macchina.

Esegue un programma binario eseguibile installato e disponibile nel file system locale dei nodi Hadoop.

Calcola statistiche come total, null, min, max, mean, stddev, zero, positive count e negative count.

Raggruppa per uno o più campi, poi esegue funzioni aggregate come avg, count, count(*), first, last, max, min, sum, collect su ciascun gruppo.

Legge da Simple Queue Service (SQS) di Amazon in pipeline in modalità flusso.

Plug-in per scrivere su Simple Queue Service (SQS) di Amazon in pipeline in modalità flusso.

Legge da Confluent Kafka in pipeline in modalità flusso.

Plug-in per scrivere su Confluent Kafka in pipeline in modalità flusso.

Origine di flussi di file che monitora una directory e trasmette i contenuti di tutti i nuovi file che vi vengono aggiunti.

Legge da Google Analytics 360 in pipeline in modalità flusso.

Si tratta di un'origine in modalità flusso che recupera i dati da un URL specificato a un determinato intervallo e passa i risultati al plug-in successivo.

Legge i dati nei formati JSON, XML, CSV, TSV, TEXT e BLOB dalle API HTTP/HTTPS in pipeline in modalità flusso.

Legge i dati da HubSpot CRM in pipeline in modalità flusso.

Origine Kafka in modalità flusso che legge gli eventi da Apache Kafka nelle pipeline in modalità flusso.

Kafka Alert Publisher che consente di pubblicare avvisi in Kafka come oggetti JSON.

Sink Kafka che consente di scrivere eventi in Kafka in formato CSV o JSON.

Sink Kinesis che restituisce un flusso Amazon Kinesis specifico.

Origine Spark in modalità flusso che legge dai flussi di dati AWS Kinesis.

Questo sink scrive in un argomento Pub/Sub nelle pipeline in modalità flusso.

Questa origine legge in tempo reale da una sottoscrizione Pub/Sub.

Questa origine monitora gli aggiornamenti degli sObject Salesforce. Esempi di sObject sono opportunità, contatti, account, lead, oggetti personalizzati ecc.

Legge da Splunk in pipeline in modalità flusso.

Plug-in per scrivere su Splunk in pipeline in modalità batch e flusso.

Campiona tweet in tempo reale tramite Spark. I record di output avranno questo schema.

Il plug-in Window viene utilizzato per visualizzare in finestre una parte di una pipeline in modalità flusso.

Trash consuma tutti i record dell'input, quindi non viene generato né memorizzato alcun output.