Plugin Cloud Data Fusion

Sumber ini membaca seluruh konten tabel BigQuery.

Sink ini menulis ke beberapa tabel BigQuery. Data pertama-tama ditulis ke lokasi sementara di Cloud Storage, lalu dimuat ke BigQuery dari sana.

Sink ini menulis ke tabel BigQuery. Data pertama-tama ditulis ke lokasi sementara di Cloud Storage, lalu dimuat ke BigQuery dari sana.

Plugin sumber ini membaca objek dari jalur di bucket Cloud Storage.

Plugin sink ini menulis kumpulan data ke satu atau beberapa file di direktori pada Cloud Storage dalam berbagai format seperti CSV, Avro, Parquet, dan JSON.

Membaca dari beberapa tabel dalam database. Digunakan dengan plugin multi-sink seperti multi-sink Cloud Storage dan multi-sink BigQuery untuk memuat data dari seluruh database dalam satu pipeline.

Membaca dari instance MySQL menggunakan kueri SQL yang dapat dikonfigurasi. Menghasilkan satu kumpulan data untuk setiap baris yang ditampilkan oleh kueri.

Membaca dari tabel Oracle menggunakan kueri SQL yang dapat dikonfigurasi. Menghasilkan satu kumpulan data untuk setiap baris yang ditampilkan oleh kueri.

Sumber ini membaca sObject seperti peluang, kontak, akun, prospek, objek kustom apa pun, dll. dari Salesforce dalam batch.

Menghubungkan ke sumber SAP untuk ekstraksi data berbasis batch dan delta melalui Operational Data Provisioning (ODP).

Membaca dari SQL Server menggunakan kueri SQL yang dapat dikonfigurasi. Menghasilkan satu kumpulan data untuk setiap baris yang ditampilkan oleh kueri.

Sumber ini membaca seluruh konten tabel BigQuery.

Membaca dari tabel BigQuery untuk mengambil argumen yang akan disetel di pipeline.

Plugin ini menjalankan Kueri SQL BigQuery.

Sink ini menulis ke beberapa tabel BigQuery. Data pertama-tama ditulis ke lokasi sementara di Cloud Storage, lalu dimuat ke BigQuery dari sana.

Sink ini menulis ke tabel BigQuery. Data pertama-tama ditulis ke lokasi sementara di Cloud Storage, lalu dimuat ke BigQuery dari sana.

Sink batch yang menulis data ke Cloud Bigtable.

Sumber ini membaca data dari Cloud Bigtable.

Menyerap data ke salah satu aset yang didukung Dataplex.

Membaca data dari entitas (tabel) Dataplex yang ada di aset Cloud Storage atau BigQuery.

Sumber ini membaca data dari Datastore. Datastore adalah database dokumen NoSQL yang dibangun untuk penskalaan otomatis dan performa tinggi.

Sink ini menulis data ke Cloud Datastore. Datastore adalah database dokumen NoSQL yang dibangun untuk penskalaan otomatis dan performa tinggi.

Membaca dari Cloud Firestore dalam pipeline batch.

Plugin untuk menulis ke Cloud Firestore dalam pipeline batch dan streaming.

Plugin sink ini menulis kumpulan data ke satu atau beberapa file di direktori pada Cloud Storage dalam berbagai format seperti CSV, Avro, Parquet, dan JSON.

Plugin sumber ini membaca objek dari jalur di bucket Cloud Storage.

Membaca dari file Cloud Storage untuk mengambil argumen yang akan disetel dalam pipeline.

Plugin ini menghapus objek di bucket Cloud Storage.

Plugin ini menyalin objek dari bucket Cloud Storage ke bucket lainnya. Satu objek dapat disalin, atau direktori objek dapat disalin.

Plugin ini membuat objek di bucket Cloud Storage.

Membuat file DONE (atau SUCCESS) kosong di bucket Cloud Storage tertentu setelah pipeline selesai, berhasil, atau gagal, untuk mengatur proses dependen.

Plugin ini memindahkan objek dari satu bucket Cloud Storage ke bucket lainnya. Satu objek dapat dipindahkan, atau direktori objek dapat dipindahkan.

Plugin ini digunakan bersamaan dengan sumber MultiTableDatabase untuk menulis kumpulan data dari beberapa database ke dalam direktori terpisah.

Mendekripsi data sensitif yang sebelumnya dienkripsi oleh Cloud Data Loss Prevention (DLP) menggunakan transformasi enkripsi yang dapat dibalik, seperti Format Preserving Encryption.

Memisahkan kumpulan data sensitif berdasarkan apakah data tersebut cocok dengan template yang ditentukan pengguna menggunakan API Cloud Data Loss Prevention (DLP).

Menyamarkan kumpulan data sensitif menggunakan Cloud Data Loss Prevention (DLP) dengan mencocokkan beberapa filter DLP yang telah ditentukan sebelumnya atau template kustom yang ditentukan pengguna.

Membaca file dari direktori Google Drive tertentu melalui Google Drive API.

Plugin sink menyimpan file dari pipeline ke direktori Google Drive melalui Google Drive API.

Menulis spreadsheet ke direktori Google Drive yang ditentukan.

Membaca spreadsheet dari direktori Google Drive yang ditentukan.

Sink ini menulis ke topik Pub/Sub di pipeline streaming.

Sumber ini membaca dari langganan Pub/Sub secara realtime.

Sink ini menulis ke tabel Cloud Spanner.

Sumber ini membaca dari tabel Cloud Spanner.

Plugin ini melakukan konversi file audio menjadi teks dengan menggunakan Speech-to-Text.

Mengelompokkan menurut satu atau beberapa kolom, lalu melakukan fungsi agregat seperti avg, count, count(*), first, last, max, min, sum, collect di setiap grup.

Menggabungkan kumpulan data dari satu atau beberapa input berdasarkan kunci gabungan. Mendukung gabungan dalam dan luar, pemilihan, dan penggantian nama kolom output.

Top N menampilkan kumpulan data "n" teratas dari kumpulan input, berdasarkan kriteria yang ditentukan dalam konfigurasi plugin.

Menerapkan fungsi agregasi pada jendela data.

Mengirim email di akhir proses pipeline.

Tindakan untuk mengirim email di akhir proses pipeline.

Membuat file DONE (atau SUCCESS) kosong di bucket Cloud Storage tertentu setelah pipeline selesai, berhasil, atau gagal, untuk mengatur proses dependen.

Menjalankan permintaan HTTP di akhir proses pipeline.

Kafka Alert Publisher yang memungkinkan Anda memublikasikan peringatan ke Kafka sebagai objek JSON.

Menjalankan kueri MariaDB di akhir proses pipeline. Dapat dikonfigurasi untuk berjalan hanya pada saat berhasil, hanya pada saat gagal, atau selalu pada akhir proses.

Menjalankan kueri Netezza di akhir proses pipeline. Dapat dikonfigurasi untuk berjalan hanya pada saat berhasil, hanya pada saat gagal, atau selalu pada akhir proses.

Menjalankan kueri Oracle di akhir proses pipeline. Dapat dikonfigurasi untuk berjalan hanya pada saat berhasil, hanya pada saat gagal, atau selalu pada akhir proses.

Menjalankan kueri PostgreSQL di akhir proses pipeline. Dapat dikonfigurasi untuk berjalan hanya pada saat berhasil, hanya pada saat gagal, atau selalu pada akhir proses.

Menjalankan kueri SQL Server di akhir proses pipeline. Dapat dikonfigurasi untuk berjalan hanya pada saat berhasil, hanya pada saat gagal, atau selalu pada akhir proses.

Menjalankan kueri Teradata di akhir proses pipeline. Dapat dikonfigurasi untuk berjalan hanya pada saat berhasil, hanya pada saat gagal, atau selalu pada akhir proses.

Menerbitkan peringatan ke CDAP Transactional Messaging System (TMS) sebagai objek JSON.

Sink batch yang menulis data ke Apache Cassandra.

Sumber batch yang membaca dari Apache Cassandra.

Menulis kumpulan data ke tabel HBase dengan satu kolom yang dipetakan ke row key, dan semua kolom kumpulan data lainnya yang dipetakan ke penentu kolom.

Sumber batch yang membaca dari grup kolom dalam tabel HBase.

Hive Export akan mengambil kueri yang dipilih sebagai input untuk menjalankan kueri tersebut pada tabel hive dan menyimpan hasilnya di lokasi yang ditentukan.

Tindakan untuk mengambil data dari endpoint http eksternal dan membuat file di HDFS.

Kafka Alert Publisher yang memungkinkan Anda memublikasikan peringatan ke Kafka sebagai objek JSON.

Sumber batch Kafka yang membaca peristiwa dari Apache Kafka dalam pipeline batch.

Sumber streaming Kafka yang membaca peristiwa dari Apache Kafka dalam pipeline streaming.

Sink Kafka yang memungkinkan Anda menulis peristiwa ke CSV atau JSON ke Kafka.

Menjalankan kode Spark yang disediakan pengguna di Python.

Plugin ini mempartisi ulang RDD Spark.

Menjalankan kode Spark yang disediakan pengguna di Scala yang mentransformasi RDD menjadi RDD dengan akses penuh ke semua fitur Spark.

Menjalankan kode Spark yang disediakan pengguna di Scala.

Menjalankan kode Spark yang disediakan pengguna di Scala yang beroperasi pada RDD input atau Dataframe dengan akses penuh ke semua fitur Spark.

Mengurai log dari sumber input apa pun untuk informasi yang relevan seperti URI, IP, browser, perangkat, kode status HTTP, dan stempel waktu.

Plugin sumber untuk memuat data dari model Anaplan ke dalam pipeline data.

Plugin sink untuk mendukung impor data dari CDAP ke server Anaplan.

Melakukan Tindakan/Proses yang telah ditentukan sebelumnya dalam model Anaplan tertentu. Ini biasa digunakan untuk mempersiapkan impor dan ekspor data.

Membaca Data iklan dari Facebook Insights API dalam pipeline batch.

Membaca dari Google Analytics 360 dalam pipeline batch.

Membaca dari Google Analytics 360 dalam pipeline streaming.

Membaca file dari direktori Google Drive tertentu melalui Google Drive API.

Plugin sink menyimpan file dari pipeline ke direktori Google Drive melalui Google Drive API.

Menulis spreadsheet ke direktori Google Drive yang ditentukan.

Membaca spreadsheet dari direktori Google Drive yang ditentukan.

Membaca data dalam format JSON, XML, CSV, TSV, TEXT, dan BLOB dari API HTTP/HTTPS dalam pipeline batch.

Plugin sink untuk mengirim pesan dari pipeline ke endpoint http eksternal.

Menjalankan permintaan HTTP di akhir proses pipeline.

Ini adalah sumber streaming yang akan mengambil data dari URL tertentu pada interval tertentu dan meneruskan hasilnya ke plugin berikutnya.

Membaca data dalam format JSON, XML, CSV, TSV, TEXT, dan BLOB dari API HTTP/HTTPS di pipeline streaming.

Tindakan untuk mengambil data dari endpoint http eksternal dan membuat file di HDFS.

Plugin untuk menulis data ke CRM HubSpot dalam pipeline batch dan streaming.

Membaca data dari CRM HubSpot di pipeline streaming.

Membaca data dari CRM HubSpot dalam pipeline batch.

Sumber ini membaca sObject seperti peluang, kontak, akun, prospek, objek kustom apa pun, dll. dari Salesforce dalam batch.

Sumber ini melacak pembaruan di sObject Salesforce. Contoh sObject adalah peluang, kontak, akun, prospek, objek kustom apa pun, dll.

Sink batch yang menyisipkan sObject seperti peluang, kontak, akun, prospek, objek kustom apa pun, dll. ke dalam Salesforce.

Sumber ini melacak pembaruan di sObject Salesforce seperti peluang, kontak, akun, prospek, objek kustom apa pun, dll.

Sink ini menyisipkan kumpulan data ke dalam Ekstensi Data Salesforce Marketing Cloud (SFMC) melalui integrasi server-ke-server dengan SFMC API.

Sumber ini membaca beberapa sObject dari Salesforce. Ini harus digunakan bersama dengan multi-sink.

Membaca dari satu atau beberapa tabel dalam ServiceNow.

Plugin ini melakukan konversi file audio menjadi teks dengan menggunakan Speech-to-Text.

Membaca objek seperti Komentar Artikel, Komentar Postingan, Komentar Permintaan, Komentar Tiket, Grup, Organisasi, Rating Kepuasan, Tag, Kolom Tiket, Metrik Tiket, Peristiwa Metrik Tiket, Tiket, Pengguna dari Zendesk.

Multi-sumber yang membaca beberapa objek dari Zendesk dan merutekannya ke tujuan tertentu. Harus digunakan bersama dengan multi-sink.

Menulis ke sistem file dalam berbagai format.

Sumber ini digunakan kapan pun Anda perlu membaca dari sistem file terdistribusi.

Menulis kumpulan data ke satu atau beberapa file dalam direktori di Cloud Storage dalam berbagai format seperti CSV, Avro, Parquet, dan JSON.

Sumber ini digunakan kapan pun Anda perlu membaca dari Amazon S3.

Sink ini digunakan untuk menulis ke Amazon S3 dalam berbagai format.

Amazon S3 Client Action digunakan untuk bekerja dengan bucket dan objek S3 sebelum atau setelah eksekusi pipeline.

Menghapus duplikat kumpulan data menggunakan satu atau beberapa kolom atau dengan menggunakan kumpulan data secara keseluruhan. Selain itu, ini mendukung pemilihan kumpulan data secara logis dari kumpulan data duplikat berdasarkan kolom filter. Fungsi logis yang didukung adalah max, min, first, dan last.

Menghapus duplikat kumpulan data input sehingga semua kumpulan data output berbeda.

Memfilter pesan berdasarkan kriteria tertentu.

Memisahkan kumpulan data sensitif berdasarkan apakah data tersebut cocok dengan template yang ditentukan pengguna menggunakan API Cloud Data Loss Prevention (DLP).

Plugin ini menerapkan perintah transformasi data yang dihasilkan melalui UI interaktif atau secara manual pada kumpulan data Anda.

Sumber ini digunakan kapan pun Anda perlu membaca dari Amazon S3.

Sumber batch untuk menggunakan Microsoft Azure Blob Storage sebagai sumber.

Memuat data dari file stage eksternal atau internal di Cloud Storage ke tabel Snowflake yang ada.

Plugin sink ini menulis kumpulan data ke satu atau beberapa file di direktori pada Cloud Storage dalam berbagai format seperti CSV, Avro, Parquet, dan JSON.

Plugin ini membaca objek dari jalur di bucket Cloud Storage.

Membaca dari file Cloud Storage untuk mengambil argumen yang akan disetel dalam pipeline.

Plugin ini menghapus objek di bucket Cloud Storage.

Plugin ini menyalin objek dari bucket Cloud Storage ke bucket lainnya. Satu objek dapat disalin, atau direktori objek dapat disalin.

Plugin ini membuat objek di bucket Cloud Storage.

Plugin ini memindahkan objek dari satu bucket Cloud Storage ke bucket lainnya. Satu objek dapat dipindahkan, atau direktori objek dapat dipindahkan.

Plugin ini digunakan bersamaan dengan sumber MultiTableDatabase untuk menulis kumpulan data dari beberapa database ke dalam direktori terpisah.

Membuat file DONE (atau SUCCESS) kosong di bucket Cloud Storage tertentu setelah pipeline selesai, berhasil, atau gagal, untuk mengatur proses dependen.

Menjalankan JavaScript yang disediakan pengguna yang mentransformasi satu kumpulan data menjadi nol atau beberapa kumpulan data.

Menjalankan kode Spark yang disediakan pengguna di Python.

Menjalankan kode Python yang disediakan pengguna untuk mentransformasi kumpulan data input, yang tersedia sebagai kamus Python.

Menjalankan kode Spark yang disediakan pengguna di Scala yang mentransformasi RDD menjadi RDD dengan akses penuh ke semua fitur Spark.

Menjalankan kode Spark yang disediakan pengguna di Scala.

Menjalankan kode Spark yang disediakan pengguna di Scala yang beroperasi pada RDD input atau Dataframe dengan akses penuh ke semua fitur Spark.

Mengompresi kolom yang dikonfigurasi menggunakan algoritma kompresi yang berbeda seperti SNAPPY, ZIP, dan GZIP.

Mendekompresi kolom yang dikonfigurasi menggunakan algoritma kompresi seperti SNAPPY, ZIP, dan GZIP.

Plugin aliran kontrol yang memungkinkan eksekusi kondisional dalam pipeline berdasarkan ekspresi.

Mengumpulkan kesalahan yang dikeluarkan dari stage sebelumnya dan menambahkan pesan error kode, dan stage ke kumpulan data.

Sink batch yang menyebabkan pipeline gagal segera setelah menerima kumpulan data pertama.

Plugin ini mengirimkan kumpulan data dengan nilai null untuk kolom tertentu ke port null dan kumpulan data dengan nilai bukan null ke port bukan null.

Merutekan kumpulan data ke port yang sesuai berdasarkan evaluasi ekspresi pada nilai salah satu kolomnya atau lebih.

Pemisah union digunakan untuk memisahkan data berdasarkan skema union, sehingga logika khusus jenis dapat dilakukan di downstream.

Melakukan Tindakan/Proses yang telah ditentukan sebelumnya dalam model Anaplan tertentu. Ini biasa digunakan untuk mempersiapkan impor dan ekspor data.

Menjalankan kueri SQL di awal atau akhir pipeline.

Tindakan yang menjalankan perintah database.

Menjalankan kueri database di akhir proses pipeline. Dapat dikonfigurasi untuk berjalan hanya pada saat berhasil, hanya pada saat gagal, atau selalu pada akhir proses.

Tindakan yang menjalankan perintah DB2.

Plugin tindakan ini dapat digunakan untuk memeriksa apakah file kosong atau apakah konten file cocok dengan pola yang diberikan.

Menghapus satu file atau beberapa file.

Memindahkan satu file atau beberapa file.

Menyalin file dari server FTP ke tujuan yang ditentukan.

Menyalin file ke server FTP dari tujuan tertentu.

Plugin ini menghapus objek di bucket Cloud Storage.

Plugin ini menyalin objek dari bucket Cloud Storage ke bucket lainnya. Satu objek dapat disalin, atau direktori objek dapat disalin.

Plugin ini membuat objek di bucket Cloud Storage.

Plugin ini memindahkan objek dari satu bucket Cloud Storage ke bucket lainnya. Satu objek dapat dipindahkan, atau direktori objek dapat dipindahkan.

Tindakan untuk mengambil data dari endpoint http eksternal dan membuat file di HDFS.

Tindakan yang menjalankan perintah MariaDB.

Tindakan yang menjalankan perintah MySQL.

Tindakan yang menjalankan perintah Netezza.

Tindakan yang menjalankan perintah Oracle.

Plugin Action untuk mengekspor data secara efisien dari Oracle ke sistem file menggunakan alat command line Oracle.

Tindakan yang menjalankan perintah PostgreSQL.

Membuat koneksi SSH dengan mesin jarak jauh untuk menjalankan perintah pada mesin tersebut.

SFTP Copy memungkinkan penyalinan file dari direktori tertentu di server SFTP ke tujuan yang ditentukan.

Plugin CDAP Action untuk menghapus file tertentu dari server SFTP.

SFTP put memungkinkan upload file dari sistem file (lokal/HDFS) ke server FTP. File Regex juga dapat digunakan untuk memfilter hanya file yang diinginkan.

Menjalankan kueri SQL tertentu di Snowflake.

Tindakan yang menjalankan perintah SQL Server.

Tindakan yang menjalankan perintah Teradata.

Menyalin satu atau beberapa file saat berbagi dari Microsoft Windows ke sistem file.

Plugin untuk menulis data ke CRM HubSpot dalam pipeline batch dan streaming.

Membaca data dari CRM HubSpot di pipeline streaming.

Membaca data dari CRM HubSpot dalam pipeline batch.

Sumber ini membaca sObject seperti peluang, kontak, akun, prospek, objek kustom apa pun, dll. dari Salesforce dalam batch.

Sink batch yang menyisipkan sObject seperti peluang, kontak, akun, prospek, objek kustom apa pun, dll. ke dalam Salesforce.

Sumber ini melacak pembaruan di sObject Salesforce. Contoh sObject adalah peluang, kontak, akun, prospek, objek kustom apa pun, dll.

Sumber ini melacak pembaruan di sObject Salesforce seperti peluang, kontak, akun, prospek, objek kustom apa pun, dll.

Sink ini menyisipkan kumpulan data ke dalam Ekstensi Data Salesforce Marketing Cloud (SFMC) melalui integrasi server-ke-server dengan SFMC API.

Sumber ini membaca beberapa sObject dari Salesforce. Ini harus digunakan bersama dengan multi-sink.

Memformat input ke dalam Kumpulan Data CSV menggunakan format seperti DELIMITED, EXCEL, MYSQL, RFC4180, dan TDF.

Mengurai Kumpulan Data CSV yang diformat sebagai DEFAULT, EXCEL, MYSQL, RFC4180, Tab Delimited, Pipe Delimited menjadi Kumpulan Data Terstruktur.

Menulis ke sistem file dalam berbagai format.

Sumber ini digunakan kapan pun Anda perlu membaca dari sistem file terdistribusi.

Plugin sink ini menulis kumpulan data ke satu atau beberapa file di direktori pada Cloud Storage dalam berbagai format seperti CSV, Avro, Parquet, dan JSON.

Sink Kafka yang memungkinkan Anda menulis peristiwa ke CSV atau JSON ke Kafka.

Sink batch yang menulis data ke Cloud Bigtable.

Sumber ini membaca data dari Cloud Bigtable.

Tindakan yang menjalankan perintah database.

Membaca dari database menggunakan kueri SQL yang dapat dikonfigurasi. Menghasilkan satu kumpulan data untuk setiap baris yang ditampilkan oleh kueri.

Menulis kumpulan data ke tabel database. Setiap kumpulan data akan ditulis ke baris dalam tabel.

Membaca dari tabel database relasional untuk mengambil argumen yang akan disetel dalam pipeline.

Menjalankan kueri database di akhir proses pipeline. Dapat dikonfigurasi untuk berjalan hanya pada saat berhasil, hanya pada saat gagal, atau selalu pada akhir proses.

Membaca dari DB2 menggunakan kueri SQL yang dapat dikonfigurasi. Menghasilkan satu kumpulan data untuk setiap baris yang ditampilkan oleh kueri.

Menjalankan kueri DB2 di akhir proses pipeline. Dapat dikonfigurasi untuk berjalan hanya pada saat berhasil, hanya pada saat gagal, atau selalu pada akhir proses.

Tindakan yang menjalankan perintah DB2.

Menulis kumpulan data ke tabel DB2. Setiap kumpulan data akan ditulis ke baris dalam tabel.

Menulis kumpulan data ke tabel MariaDB. Setiap kumpulan data akan ditulis ke baris dalam tabel.

Membaca dari MariaDB menggunakan kueri SQL yang dapat dikonfigurasi. Menghasilkan satu kumpulan data untuk setiap baris yang ditampilkan oleh kueri.

Menjalankan kueri MariaDB di akhir proses pipeline. Dapat dikonfigurasi untuk berjalan hanya pada saat berhasil, hanya pada saat gagal, atau selalu pada akhir proses.

Tindakan yang menjalankan perintah MariaDB.

Membaca dari beberapa tabel dalam database. Digunakan dengan plugin multi-sink seperti, multi-sink Cloud Storage dan multi-sink BigQuery untuk memuat data dari seluruh database dalam satu pipeline.

Menjalankan kueri MySQL di akhir proses pipeline. Dapat dikonfigurasi untuk berjalan hanya pada saat berhasil, hanya pada saat gagal, atau selalu pada akhir proses.

Menulis kumpulan data ke tabel MySQL. Setiap kumpulan data akan ditulis ke baris dalam tabel.

Membaca dari instance MySQL menggunakan kueri SQL yang dapat dikonfigurasi. Menghasilkan satu kumpulan data untuk setiap baris yang ditampilkan oleh kueri.

Tindakan yang menjalankan perintah MySQL.

Membaca dari tabel Oracle menggunakan kueri SQL yang dapat dikonfigurasi. Menghasilkan satu kumpulan data untuk setiap baris yang ditampilkan oleh kueri.

Menulis kumpulan data ke tabel Oracle. Setiap kumpulan data akan ditulis ke baris dalam tabel.

Menjalankan kueri Oracle di akhir proses pipeline. Dapat dikonfigurasi untuk berjalan hanya pada saat berhasil, hanya pada saat gagal, atau selalu pada akhir proses.

Tindakan yang menjalankan perintah Oracle.

Plugin Action untuk mengekspor data secara efisien dari Oracle ke sistem file menggunakan alat command line Oracle.

Membaca dari PostgreSQL menggunakan kueri SQL yang dapat dikonfigurasi. Menghasilkan satu kumpulan data untuk setiap baris yang ditampilkan oleh kueri.

Menulis kumpulan data ke tabel PostgreSQL. Setiap kumpulan data akan ditulis ke baris dalam tabel.

Menjalankan kueri PostgreSQL di akhir proses pipeline. Dapat dikonfigurasi untuk berjalan hanya pada saat berhasil, hanya pada saat gagal, atau selalu pada akhir proses.

Tindakan yang menjalankan perintah PostgreSQL.

Sink ini menulis ke tabel Cloud Spanner.

Sumber ini membaca dari tabel Cloud Spanner.

Menulis kumpulan data ke tabel SQL Server. Setiap kumpulan data akan ditulis ke baris dalam tabel.

Menjalankan kueri SQL Server di akhir proses pipeline. Dapat dikonfigurasi untuk berjalan hanya pada saat berhasil, hanya pada saat gagal, atau selalu pada akhir proses.

Membaca dari SQL Server menggunakan kueri SQL yang dapat dikonfigurasi. Menghasilkan satu kumpulan data untuk setiap baris yang ditampilkan oleh kueri.

Tindakan yang menjalankan perintah SQL Server.

DB2 Menjalankan kueri DB2 di akhir proses pipeline. Dapat dikonfigurasi untuk berjalan hanya pada saat berhasil, hanya pada saat gagal, atau selalu pada akhir proses.

Sumber ini membaca seluruh konten tabel BigQuery.

Membaca dari tabel BigQuery untuk mengambil argumen yang akan disetel di pipeline.

Plugin ini menjalankan kueri SQL BigQuery.

Sink ini menulis ke beberapa tabel BigQuery. Data pertama-tama ditulis ke lokasi sementara di Cloud Storage, lalu dimuat ke BigQuery dari sana.

Sink ini menulis ke tabel BigQuery. Data pertama-tama ditulis ke lokasi sementara di Cloud Storage, lalu dimuat ke BigQuery dari sana.

Memuat data dari file stage eksternal atau internal di Cloud Storage ke tabel Snowflake yang ada.

Hive Export akan mengambil kueri yang dipilih sebagai input untuk menjalankan kueri tersebut pada tabel hive dan menyimpan hasilnya di lokasi yang ditentukan.

Menulis kumpulan data ke tabel Netezza. Setiap kumpulan data akan ditulis ke baris dalam tabel.

Membaca dari Netezza menggunakan kueri SQL yang dapat dikonfigurasi. Menghasilkan satu kumpulan data untuk setiap baris yang ditampilkan oleh kueri.

Menjalankan kueri Netezza di akhir proses pipeline. Dapat dikonfigurasi untuk berjalan hanya pada saat berhasil, hanya pada saat gagal, atau selalu pada akhir proses.

Tindakan yang menjalankan perintah Netezza.

Membuat representasi SCD2 dari kumpulan data dengan mengelompokkan kumpulan data sumber berdasarkan kunci yang ditentukan dan menghasilkan tanggal mulai dan berakhir (kedaluwarsa).

Menulis data ke tabel Snowflake dalam pipeline batch.

Membaca data dari tabel Snowflake dalam pipeline batch.

Menjalankan kueri SQL tertentu di Snowflake.

Menulis kumpulan data ke tabel Teradata. Setiap kumpulan data akan ditulis ke baris dalam tabel.

Membaca dari Teradata menggunakan kueri SQL yang dapat dikonfigurasi. Menghasilkan satu kumpulan data untuk setiap baris yang ditampilkan oleh kueri.

Menjalankan kueri Teradata di akhir proses pipeline. Dapat dikonfigurasi untuk berjalan hanya pada saat berhasil, hanya pada saat gagal, atau selalu pada akhir proses.

Tindakan yang menjalankan perintah Teradata.

Mendekripsi data sensitif yang sebelumnya dienkripsi oleh Cloud Data Loss Prevention (DLP) menggunakan transformasi enkripsi yang dapat dibalik, seperti Format Preserving Encryption.

Memisahkan kumpulan data sensitif berdasarkan apakah data tersebut cocok dengan template yang ditentukan pengguna menggunakan API Cloud Data Loss Prevention (DLP).

Menyamarkan kumpulan data sensitif menggunakan Cloud Data Loss Prevention (DLP) dengan mencocokkan beberapa filter DLP yang telah ditentukan sebelumnya atau template kustom yang ditentukan pengguna.

Melakukan permintaan HTTP untuk mengambil argumen yang akan disetel dalam pipeline.

Membaca dari tabel database relasional untuk mengambil argumen yang akan disetel dalam pipeline.

Membaca dari file Cloud Storage untuk mengambil argumen yang akan disetel dalam pipeline.

Mengirim email di akhir proses pipeline.

Tindakan untuk mengirim email di akhir proses pipeline.

Membaca data tentang kampanye pemasaran yang ada, analisis email, pantulan, laporan spam dari SendGrid.

Menulis data ke SendGrid dalam pipeline batch dan streaming.

Memformat input ke dalam Kumpulan Data CSV menggunakan format seperti DELIMITED, EXCEL, MYSQL, RFC4180, dan TDF.

Mengurai Kumpulan Data CSV yang diformat sebagai DEFAULT, EXCEL, MYSQL, RFC4180, Tab Delimited, Pipe Delimited menjadi Kumpulan Data Terstruktur.

Menulis ke sistem file dalam berbagai format.

Sumber ini digunakan kapan pun Anda perlu membaca dari sistem file terdistribusi.

Sumber streaming file yang mengawasi direktori dan mengalirkan konten file dari file baru apa pun yang ditambahkan ke direktori.

Plugin sink ini ditambahkan ke file yang ada hingga mencapai batas berdasarkan ukuran atau usia.

Plugin tindakan ini dapat digunakan untuk memeriksa apakah file kosong atau apakah konten file cocok dengan pola yang diberikan.

Menghapus satu file atau beberapa file.

Memindahkan satu file atau beberapa file.

Sumber batch untuk membaca dari FTP (ftp://..) atau SFTP (sftp://...).

Menyalin file dari server FTP ke tujuan yang ditentukan.

Menyalin file ke server FTP dari tujuan tertentu.

Transformasi ini memanfaatkan library Apache PDF Box untuk mengekstrak teks dan metadata dari file PDF.

Sink ini digunakan untuk menulis ke Amazon S3 dalam berbagai format.

SFTP Copy memungkinkan penyalinan file dari direktori tertentu di server SFTP ke tujuan yang ditentukan.

Plugin CDAP Action untuk menghapus file tertentu dari server SFTP.

SFTP put memungkinkan upload file dari sistem file (lokal/HDFS) ke server FTP. File Regex juga dapat digunakan untuk memfilter hanya file yang diinginkan.

Menghapus duplikat kumpulan data menggunakan satu atau beberapa kolom atau dengan menggunakan kumpulan data secara keseluruhan. Selain itu, ini mendukung pemilihan kumpulan data secara logis dari kumpulan data duplikat berdasarkan kolom filter. Fungsi logis yang didukung adalah max, min, first, dan last.

Menghapus duplikat kumpulan data input sehingga semua kumpulan data output berbeda.

Memfilter pesan berdasarkan kriteria tertentu.

Memisahkan kumpulan data sensitif berdasarkan apakah data tersebut cocok dengan template yang ditentukan pengguna menggunakan API Cloud Data Loss Prevention (DLP).

Plugin ini mengirimkan kumpulan data dengan nilai null untuk kolom tertentu ke port null dan kumpulan data dengan nilai bukan null ke port bukan null.

Mengambil sampel dari set data besar yang mengalir melalui plugin ini untuk mengambil kumpulan data acak menggunakan pengambilan sampel sistematis atau reservoir.

Top N menampilkan kumpulan data "n" teratas dari kumpulan input, berdasarkan kriteria yang ditentukan dalam konfigurasi plugin.

Sumber batch untuk membaca dari FTP (ftp://..) atau SFTP (sftp://...).

Menyalin file dari server FTP ke tujuan yang ditentukan.

Menyalin file ke server FTP dari tujuan tertentu.

SFTP Copy memungkinkan penyalinan file dari direktori tertentu di server SFTP ke tujuan yang ditentukan.

Plugin CDAP Action untuk menghapus file tertentu dari server SFTP.

SFTP put memungkinkan upload file dari sistem file (lokal/HDFS) ke server FTP. File Regex juga dapat digunakan untuk memfilter hanya file yang diinginkan.

Membaca dari Google Analytics 360 dalam pipeline batch.

Membaca dari Google Analytics 360 dalam pipeline streaming.

Membaca file dari direktori Google Drive tertentu melalui Google Drive API.

Plugin sink menyimpan file dari pipeline ke direktori Google Drive melalui Google Drive API.

Membaca spreadsheet dari direktori Google Drive yang ditentukan.

Menulis spreadsheet ke direktori Google Drive yang ditentukan.

Menulis kumpulan data ke tabel HBase dengan satu kolom yang dipetakan ke row key, dan semua kolom kumpulan data lainnya yang dipetakan ke penentu kolom.

Sumber batch yang membaca dari grup kolom dalam tabel HBase.

Hive Export akan mengambil kueri yang dipilih sebagai input untuk menjalankan kueri tersebut pada tabel hive dan menyimpan hasilnya di lokasi yang ditentukan.

Tindakan untuk mengambil data dari endpoint http eksternal dan membuat file di HDFS.

Plugin XML Reader adalah plugin sumber yang memungkinkan pengguna membaca file XML yang disimpan di HDFS.

Tindakan untuk mengambil data dari endpoint http eksternal dan membuat file di HDFS.

Melakukan permintaan HTTP untuk mengambil argumen yang akan disetel dalam pipeline.

Membaca dari DB2 menggunakan kueri SQL yang dapat dikonfigurasi. Menghasilkan satu kumpulan data untuk setiap baris yang ditampilkan oleh kueri.

Menjalankan kueri DB2 di akhir proses pipeline. Dapat dikonfigurasi untuk berjalan hanya pada saat berhasil, hanya pada saat gagal, atau selalu pada akhir proses.

Tindakan yang menjalankan perintah DB2.

Menulis kumpulan data ke tabel DB2. Setiap kumpulan data akan ditulis ke baris dalam tabel.

Menulis kumpulan data ke tabel Netezza. Setiap kumpulan data akan ditulis ke baris dalam tabel.

Membaca dari Netezza menggunakan kueri SQL yang dapat dikonfigurasi. Menghasilkan satu kumpulan data untuk setiap baris yang ditampilkan oleh kueri.

Menjalankan kueri Netezza di akhir proses pipeline. Dapat dikonfigurasi untuk berjalan hanya pada saat berhasil, hanya pada saat gagal, atau selalu pada akhir proses.

Tindakan yang menjalankan perintah Netezza.

Membaca dari database menggunakan kueri SQL yang dapat dikonfigurasi. Menghasilkan satu kumpulan data untuk setiap baris yang ditampilkan oleh kueri.

Menulis kumpulan data ke tabel database. Setiap kumpulan data akan ditulis ke baris dalam tabel.

Membaca dokumen dari koleksi MongoDB dan melakukan konversi setiap dokumen menjadi StructuredRecord dengan bantuan skema tertentu.

Sink ini menulis ke koleksi MongoDB.

Menjalankan kueri MySQL di akhir proses pipeline. Dapat dikonfigurasi untuk berjalan hanya pada saat berhasil, hanya pada saat gagal, atau selalu pada akhir proses.

Menulis kumpulan data ke tabel MySQL. Setiap kumpulan data akan ditulis ke baris dalam tabel.

Membaca dari instance MySQL menggunakan kueri SQL yang dapat dikonfigurasi. Menghasilkan satu kumpulan data untuk setiap baris yang ditampilkan oleh kueri.

Tindakan yang menjalankan perintah MySQL.

Menulis kumpulan data ke tabel Netezza. Setiap kumpulan data akan ditulis ke baris dalam tabel.

Membaca dari Netezza menggunakan kueri SQL yang dapat dikonfigurasi. Menghasilkan satu kumpulan data untuk setiap baris yang ditampilkan oleh kueri.

Menjalankan kueri Netezza di akhir proses pipeline. Dapat dikonfigurasi untuk berjalan hanya pada saat berhasil, hanya pada saat gagal, atau selalu pada akhir proses.

Tindakan yang menjalankan perintah Netezza.

Membaca dari tabel Oracle menggunakan kueri SQL yang dapat dikonfigurasi. Menghasilkan satu kumpulan data untuk setiap baris yang ditampilkan oleh kueri.

Menulis kumpulan data ke tabel Oracle. Setiap kumpulan data akan ditulis ke baris dalam tabel.

Menjalankan kueri Oracle di akhir proses pipeline. Dapat dikonfigurasi untuk berjalan hanya pada saat berhasil, hanya pada saat gagal, atau selalu pada akhir proses.

Tindakan yang menjalankan perintah Oracle.

Plugin Action untuk mengekspor data secara efisien dari Oracle ke sistem file menggunakan alat command line Oracle.

Membaca dari PostgreSQL menggunakan kueri SQL yang dapat dikonfigurasi. Menghasilkan satu kumpulan data untuk setiap baris yang ditampilkan oleh kueri.

Menulis kumpulan data ke tabel PostgreSQL. Setiap kumpulan data akan ditulis ke baris dalam tabel.

Menjalankan kueri PostgreSQL di akhir proses pipeline. Dapat dikonfigurasi untuk berjalan hanya pada saat berhasil, hanya pada saat gagal, atau selalu pada akhir proses.

Tindakan yang menjalankan perintah PostgreSQL.

Menulis kumpulan data ke tabel SQL Server. Setiap kumpulan data akan ditulis ke baris dalam tabel.

Menjalankan kueri SQL Server di akhir proses pipeline. Dapat dikonfigurasi untuk berjalan hanya pada saat berhasil, hanya pada saat gagal, atau selalu pada akhir proses.

Membaca dari SQL Server menggunakan kueri SQL yang dapat dikonfigurasi. Menghasilkan satu kumpulan data untuk setiap baris yang ditampilkan oleh kueri.

Tindakan yang menjalankan perintah SQL Server.

Menulis kumpulan data ke tabel Teradata. Setiap kumpulan data akan ditulis ke baris dalam tabel.

Membaca dari Teradata menggunakan kueri SQL yang dapat dikonfigurasi. Menghasilkan satu kumpulan data untuk setiap baris yang ditampilkan oleh kueri.

Menjalankan kueri Teradata di akhir proses pipeline. Dapat dikonfigurasi untuk berjalan hanya pada saat berhasil, hanya pada saat gagal, atau selalu pada akhir proses.

Tindakan yang menjalankan perintah Teradata.

Menulis data ke Elasticsearch sebagai string JSON, lalu mengindeksnya menggunakan indeks, jenis, dan idField yang ditentukan oleh pengguna.

Menulis kumpulan data ke satu atau beberapa file dalam direktori di Cloud Storage dalam berbagai format seperti CSV, Avro, Parquet, dan JSON.

Memformat kumpulan data terstruktur sebagai Objek JSON.

Mengurai peristiwa JSON input ke dalam kumpulan data menggunakan jalur JSON untuk mengekstrak kolom dari JSON input susun bertingkat dan kompleks.

Sink Kafka yang memungkinkan Anda menulis peristiwa ke CSV atau JSON ke Kafka.

Menerima kolom yang berisi string XML yang diformat dengan benar dan menghasilkan versi string JSON data yang diformat dengan benar.

Membaca dari Confluent Kafka di pipeline streaming.

Plugin untuk menulis ke Confluent Kafka di pipeline streaming.

Sumber batch Kafka yang membaca peristiwa dari Apache Kafka dalam pipeline batch.

Sumber streaming Kafka yang membaca peristiwa dari Apache Kafka dalam pipeline streaming.

Kafka Alert Publisher yang memungkinkan Anda memublikasikan peringatan ke Kafka sebagai objek JSON.

Sink Kafka yang memungkinkan Anda menulis peristiwa ke CSV atau JSON ke Kafka.

Mengurai log dari sumber input apa pun untuk informasi yang relevan seperti URI, IP, browser, perangkat, kode status HTTP, dan stempel waktu.

Menambahkan kolom baru ke setiap kumpulan data. Nilai kolom dapat berupa UUID baru, atau dapat disetel langsung melalui konfigurasi.

Membuat salinan setiap kumpulan data input yang diterima selama sejumlah waktu yang dikonfigurasi pada output

Plugin untuk menghasilkan struktur hierarki dari skema datar.

Transformasi ini mengambil tanggal dalam stempel waktu Unix atau string dan melakukan konversi menjadi string yang diformat. (Berkemampuan makro).

Menyamarkan kumpulan data sensitif menggunakan Cloud Data Loss Prevention (DLP) dengan mencocokkan beberapa filter DLP yang telah ditentukan sebelumnya atau template kustom yang ditentukan pengguna.

Melakukan pencarian kolom tertentu dalam set data pencarian dengan mencocokkannya dengan set data input dan menyertakan kolom tersebut, serta nilainya dalam set data yang dihasilkan.

Transformasi Multi Field Adder memungkinkan Anda menambahkan satu atau beberapa kolom ke output.

Transformasi Projection memungkinkan Anda menghapus, menyimpan, mengganti nama, dan mentransmisikan kolom ke jenis yang berbeda.

Jika ada kolom dan pembatas, menghasilkan satu kumpulan data untuk setiap bagian kolom.

Melakukan konversi data mentah menjadi data yang didenormalisasi berdasarkan kolom kunci.

Membuat representasi SCD2 dari kumpulan data dengan mengelompokkan kumpulan data sumber berdasarkan kunci yang ditentukan dan menghasilkan tanggal mulai dan berakhir (kedaluwarsa).

Menormalkan data dengan mengonversi kolom menjadi baris.

Value Mapper adalah plugin transformasi yang memetakan nilai string suatu kolom dalam kumpulan data input ke nilai pemetaan menggunakan set data pemetaan.

Plugin ini menerapkan perintah transformasi data yang dihasilkan melalui UI interaktif atau secara manual pada kumpulan data Anda.

Mendekode kolom yang dikonfigurasi menggunakan metode decoding seperti STRING_BASE64, BASE64, BASE32, STRING_BASE32, dan HEX.

Mendekripsi satu atau beberapa kolom dalam kumpulan data input menggunakan keystore yang harus ada di semua node cluster.

Mengenkripsi satu atau beberapa kolom dalam kumpulan data input menggunakan keystore Java yang harus ada di semua node cluster.

Mengenkode kolom yang dikonfigurasi menggunakan metode encoding seperti STRING_BASE64, BASE64, BASE32, STRING_BASE32, dan HEX.

Mengenkode nilai kolom menggunakan algoritma digest seperti MD2, MD5, SHA1, SHA256, SHA384, dan SHA512.

Plugin Excel memberi pengguna kemampuan untuk membaca data dari satu atau beberapa file Excel.

Menyalin satu atau beberapa file saat berbagi dari Microsoft Windows ke sistem file.

Menulis data ke direktori Azure Data Lake Store dalam format avro, orc, atau teks.

Sink ini menulis ke beberapa direktori Azure Data Lake.

Sumber batch untuk menggunakan Microsoft Azure Blob Storage sebagai sumber.

Sumber Batch Azure Data Lake Store membaca data dari file Azure Data Lake Store dan melakukan konversi menjadi StructuredRecord.

Menjalankan kueri SQL Server di akhir proses pipeline. Dapat dikonfigurasi untuk berjalan hanya pada saat berhasil, hanya pada saat gagal, atau selalu pada akhir proses.

Membaca dari SQL Server menggunakan kueri SQL yang dapat dikonfigurasi. Menghasilkan satu kumpulan data untuk setiap baris yang ditampilkan oleh kueri.

Menulis kumpulan data ke tabel SQL Server. Setiap kumpulan data akan ditulis ke baris dalam tabel.

Tindakan yang menjalankan perintah SQL Server.

Plugin untuk mentransformasi data bertingkat menjadi data datar.

Sink batch yang menulis data ke Apache Cassandra.

Sumber batch yang membaca dari Apache Cassandra.

Sumber ini membaca data dari Datastore. Datastore adalah database dokumen NoSQL yang dibangun untuk penskalaan otomatis dan performa tinggi.

Sink ini menulis data ke Cloud Datastore. Datastore adalah database dokumen NoSQL yang dibangun untuk penskalaan otomatis dan performa tinggi.

Membaca dari Cloud Firestore dalam pipeline batch.

Plugin untuk menulis ke Cloud Firestore dalam pipeline batch dan streaming.

Menulis kumpulan data ke tabel HBase dengan satu kolom yang dipetakan ke row key, dan semua kolom kumpulan data lainnya yang dipetakan ke penentu kolom.

Sumber batch yang membaca dari grup kolom dalam tabel HBase.

Membaca dokumen dari koleksi MongoDB dan melakukan konversi setiap dokumen menjadi StructuredRecord dengan bantuan skema tertentu.

Sink ini menulis ke koleksi MongoDB.

Membaca dari tabel Oracle menggunakan kueri SQL yang dapat dikonfigurasi. Menghasilkan satu kumpulan data untuk setiap baris yang ditampilkan oleh kueri.

Menulis kumpulan data ke tabel Oracle. Setiap kumpulan data akan ditulis ke baris dalam tabel.

Menjalankan kueri Oracle di akhir proses pipeline. Dapat dikonfigurasi untuk berjalan hanya pada saat berhasil, hanya pada saat gagal, atau selalu pada akhir proses.

Tindakan yang menjalankan perintah Oracle.

Plugin Action untuk mengekspor data secara efisien dari Oracle ke sistem file menggunakan alat command line Oracle.

Menulis ke sistem file dalam berbagai format.

Sumber ini digunakan kapan pun Anda perlu membaca dari sistem file terdistribusi.

Menulis kumpulan data ke satu atau beberapa file dalam direktori di Cloud Storage dalam berbagai format seperti CSV, Avro, Parquet, dan JSON.

Menjalankan kode Spark yang disediakan pengguna di Python.

Menjalankan kode Python yang disediakan pengguna untuk mentransformasi kumpulan data input, yang tersedia sebagai kamus Python.

Sumber ini digunakan kapan pun Anda perlu membaca dari Amazon S3.

Mengakselerasi fitur SAP Table Batch Source untuk proses order to cash Anda.

Mengakselerasi fitur SAP Table Batch Source untuk proses procure-to-pay Anda.

Menghubungkan ke sumber SAP Ariba untuk integrasi data batch ke Google Cloud.

Menghubungkan ke sumber SAP untuk ekstraksi berbasis batch dan delta melalui Layanan BW Open Hub.

Menghubungkan ke sumber SAP untuk ekstraksi data berbasis batch menggunakan Open Data Protocol (OData).

Menghubungkan ke sumber SAP untuk ekstraksi data berbasis batch dan delta melalui Operational Data Provisioning (ODP).

Menghubungkan ke sumber SAP untuk mereplikasi data ke Google Cloud menggunakan SAP Landscape Transformation (SLT).

Menghubungkan ke sumber SAP untuk ekstraksi data berbasis batch.

Menghubungkan ke sumber SAP untuk transfer data massal dari tabel dan tampilan SAP.

Plugin sumber untuk memuat data dari model Anaplan ke dalam pipeline data.

Plugin sink untuk mendukung impor data dari CDAP ke server Anaplan.

Melakukan Tindakan/Proses yang telah ditentukan sebelumnya dalam model Anaplan tertentu. Ini biasa digunakan untuk mempersiapkan impor dan ekspor data.

Plugin untuk menulis data ke CRM HubSpot dalam pipeline batch dan streaming.

Membaca data dari CRM HubSpot di pipeline streaming.

Membaca data dari CRM HubSpot dalam pipeline batch.

Sumber ini membaca sObject seperti peluang, kontak, akun, prospek, objek kustom apa pun, dll. dari Salesforce dalam batch.

Sink batch yang menyisipkan sObject seperti peluang, kontak, akun, prospek, objek kustom apa pun, dll. ke dalam Salesforce.

Sumber ini melacak pembaruan di sObject Salesforce seperti peluang, kontak, akun, prospek, objek kustom apa pun, dll.

Sink ini menyisipkan kumpulan data ke dalam Ekstensi Data Salesforce Marketing Cloud (SFMC) melalui integrasi server-ke-server dengan SFMC API.

Sumber ini membaca beberapa sObject dari Salesforce. Ini harus digunakan bersama dengan multi-sink.

Membaca dari satu atau beberapa tabel dalam ServiceNow.

Membaca objek seperti Komentar Artikel, Komentar Postingan, Komentar Permintaan, Komentar Tiket, Grup, Organisasi, Rating Kepuasan, Tag, Kolom Tiket, Metrik Tiket, Peristiwa Metrik Tiket, Tiket, Pengguna dari Zendesk.

Multi-sumber yang membaca beberapa objek dari Zendesk dan merutekannya ke tujuan tertentu. Harus digunakan bersama dengan multi-sink.

Menarik dokumen dari Elasticsearch sesuai dengan kueri yang ditentukan oleh pengguna.

Menulis data ke Elasticsearch sebagai string JSON, lalu mengindeksnya menggunakan indeks, jenis, dan idField yang ditentukan oleh pengguna.

Memuat data dari file stage eksternal atau internal di Cloud Storage ke tabel Snowflake yang ada.

Menulis data ke tabel Snowflake dalam pipeline batch.

Membaca data dari tabel Snowflake dalam pipeline batch.

Menjalankan kueri SQL tertentu di Snowflake.

Mengurai log dari sumber input apa pun untuk informasi yang relevan seperti URI, IP, browser, perangkat, kode status HTTP, dan stempel waktu.

Menjalankan kode Spark yang disediakan pengguna di Python.

Plugin ini mempartisi ulang RDD Spark.

Menjalankan kode Spark yang disediakan pengguna di Scala yang mentransformasi RDD menjadi RDD dengan akses penuh ke semua fitur Spark.

Menjalankan kode Spark yang disediakan pengguna di Scala.

Menjalankan kode Spark yang disediakan pengguna di Scala yang beroperasi pada RDD input atau Dataframe dengan akses penuh ke semua fitur Spark.

Membuat koneksi SSH dengan mesin jarak jauh untuk menjalankan perintah pada mesin tersebut.

Menjalankan biner yang dapat dieksekusi yang terinstal dan tersedia di sistem file lokal node Hadoop.

Menghitung statistik seperti total, null, min, maks, mean, stddev, nol, jumlah positif, dan jumlah negatif.

Mengelompokkan menurut satu atau beberapa kolom, lalu melakukan fungsi agregat seperti avg, count, count(*), first, last, max, min, sum, collect di setiap grup.

Membaca dari Amazon Simple Queue Service (SQS) di pipeline streaming.

Plugin untuk menulis ke Amazon Simple Queue Service (SQS) di pipeline streaming.

Membaca dari Confluent Kafka di pipeline streaming.

Plugin untuk menulis ke Confluent Kafka di pipeline streaming.

Sumber streaming file yang mengawasi direktori dan mengalirkan konten file dari file baru apa pun yang ditambahkan ke direktori.

Membaca dari Google Analytics 360 dalam pipeline streaming.

Ini adalah sumber streaming yang akan mengambil data dari URL tertentu pada interval tertentu dan meneruskan hasilnya ke plugin berikutnya.

Membaca data dalam format JSON, XML, CSV, TSV, TEXT, dan BLOB dari API HTTP/HTTPS di pipeline streaming.

Membaca data dari CRM HubSpot di pipeline streaming.

Sumber streaming Kafka yang membaca peristiwa dari Apache Kafka dalam pipeline streaming.

Kafka Alert Publisher yang memungkinkan Anda memublikasikan peringatan ke Kafka sebagai objek JSON.

Sink Kafka yang memungkinkan Anda menulis peristiwa ke CSV atau JSON ke Kafka.

Sink ini menulis ke topik Pub/Sub di pipeline streaming.

Sumber ini membaca dari langganan Pub/Sub secara realtime.

Sumber ini melacak pembaruan di sObject Salesforce. Contoh sObject adalah peluang, kontak, akun, prospek, objek kustom apa pun, dll.

Mengambil sampel tweet secara real time melalui streaming Spark. Kumpulan data output akan memiliki skema ini.

Plugin Window digunakan untuk menampilkan suatu bagian dari pipeline streaming.

Trash mengonsumsi semua kumpulan data pada input dan menghabiskan semuanya, yang berarti tidak ada output yang dihasilkan atau tidak ada output yang disimpan di mana pun.