Reads data from Amazon S3 and converts them into CDAP's standard pipeline data format.

Writes pipeline data records to Amazon S3.

Reads data from Cassandra Key-Value tables and converts them into CDAP's standard pipeline data format.

Writes pipeline data records into Cassandra tables.

Reads data from HBase tables and converts them into CDAP's standard pipeline data format.

Writes pipeline data records into HBase tables.

Reads data from Hive tables and converts them into CDAP's standard pipeline data format.

Writes pipeline data records into Hive tables.

Pull rows from Kudu tables and converts them into CDAP's standard pipeline data format, using the Kudu native client.

Writes data records from batch and real-time pipelines into Kudu tables.

Reads data from Azure Blob Storage and converts it into CDAP's standard pipeline data format.

Reads data from Azure Data Lake store files and converts it into CDAP's standard pipeline data format.

Write pipeline data records to an Azure Data Lake store in avro, orc or text format.

Reads rows from Phoenix tables and converts them into CDAP's standard pipeline data format.

Write pipeline data records into Phoenix tables.

Reads documents from Couchbase buckets. A filter can be specified to only output documents that meet a specific criteria.

Writes data records as documents to Couchbase buckets.

Reads data from Amazon DynamoDB tables and converts them into CDAP's standard pipeline data format.

Writes pipeline data records to Amazon DynamoDB tables.

Reads indexed documents from Elasticsearch and converts them into CDAP's standard pipeline data format.

Writes pipeline data records as documents to Elasticsearch indices.

Reads the entire contents of a table from Google's BigQuery data warehouse. Data from the BigQuery table is first exported to a temporary location on Google Cloud Storage, then read into the pipeline from there.

Writes pipeline data records to a BigQuery table. Data is first written to a temporary location on Google Cloud Storage, then loaded into BigQuery from there.

Reads data from Google Cloud Bigtable. Cloud Bigtable is Google's NoSQL Big Data database service.

Writes pipeline data records to Google Cloud Bigtable.

Reads data from Google Cloud Datastore (Datastore mode). Datastore is a NoSQL document database built for automatic scaling and high performance.

Writes pipeline data records to Google Cloud Datastore (Datastore mode).

Reads objects from Google Cloud Storage buckets. Cloud Storage allows world-wide storage and retrieval of any amount of data at any time.

Writes pipeline data records to one or more files in a directory on Google Cloud Storage. Files can be written in various formats such as csv, avro, parquet, and json.

Reads documents from MongoDB collections and converts them into CDAP's standard pipeline data format.

Writes pipeline data records as documents to MongoDB collections.

Writes pipeline data records as vertices and edges to OrientDB using the Graph API.

Reads data from SAP OData service and converts them into CDAP's standard pipeline data format.

Reads real-time events and transforms them into CDAP's standard pipeline data format.

Writes pipeline data records to Amazon Kinesis streams.

Consumes real-time events from Kafka streams and transforms them into CDAP's standard pipeline data format.

Produces real-time events for Kafka streams from pipeline data records.

Reads real-time events and transforms them into CDAP's standard pipeline data format.

Reads from a Google Cloud Pub/Sub subscription in realtime. Cloud Pub/Sub brings the scalability, flexibility, and reliability of enterprise message-oriented middleware to the cloud.

Writes pipeline data records to a Google Cloud Pub/Sub topic.

Reads real-time events and transforms them into CDAP's standard pipeline data format.

Allows to subscribe to an MQTT broker and consume real-time events for a certain topic. Events are transformed into CDAP's standard pipeline data format.

PubNub is a global data stream network (DSN) and realtime network-as-a-service offering. This plugin reads realtime messages from PubNub cloud channels.

Allows users to retrieve reports of a specified report type from their Google Ads account.

Allows users to query Google Analytics Reporting API to get metrics and dimensions with built-in set.

Allows users to query Google Analytics Real Time Reporting API to get metrics and dimensions with built-in set.

Reads product data from Google Shopping Content API.

Reads sObjects, such as accounts, contacts, leads and others, by specifying SOQL (Salesforce Object Query Language) queries, or using sObject with incremental or range date filters.

Inserts pipeline data records as sObjects into Salesforce. Currently, only inserts (no upserts) are supported.

Tracks updates of sObjects using PushTopic events and transforms them into CDAP's standard pipeline data format.

Inserts pipeline data records into a Salesforce Marketing Cloud Data Extension. The sink requires Server-to-Server integration with the Salesforce Marketing Cloud API.

Fetches data from Zuora and transforms them into CDAP's standard pipeline data format. Zuora is a subscription management platform designed to meet your modern order-to-cash needs.

Writes records to a Zuora objects. Each record will be written to an object collection.

Fetches data from Zuora periodically and transforms them into CDAP's standard pipeline data format.