Wrangler Transform: A DMD system for transforming Big Data
-
Updated
Sep 19, 2024 - Java
Wrangler Transform: A DMD system for transforming Big Data
Dynamic Spark CDAP Plugins
File Source to read data from distributed file system
Kafka Source/Sink for reading/writing to kafka topic
A control flow plugin for making decisions based on runtime arguments and tokens
An action plugin for decompressing data before processing it. Useful for working with unsplittable formats.
Sink plugin to send the messages from the pipeline to an external http endpoint
CDAP plugins to read from and write to Elasticsearch in batch and realtime
Pipeline plugins that allow reading from multiple DB tables with the same source
Load data files from internal/external(amazon S3) location to Snowflake table.
Repartitions a spark RDD
A collection of Confluent and Confluent Cloud
Kinesis Spark Streaming Source Plugin: For ingesting data from Kinesis streams
Oracle Export Plugin
Add a description, image, and links to the cdap-plugin topic page so that developers can more easily learn about it.
To associate your repository with the cdap-plugin topic, visit your repo's landing page and select "manage topics."