data-integrations/wrangler

Wrangler Transform: A DMD system for transforming Big Data

Language: Java - Size: 5.75 MB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 91 - Forks: 56

data-integrations/google-cloud

A collection of Google Cloud Platform (GCP) plugins

Language: Java - Size: 11.1 MB - Last synced at: 10 days ago - Pushed at: 11 days ago - Stars: 45 - Forks: 88

data-integrations/salesforce

Salesforce plugins

Language: Java - Size: 902 KB - Last synced at: 4 days ago - Pushed at: 4 days ago - Stars: 12 - Forks: 29

data-integrations/change-data-capture 📦

Change Data Capture (CDC) plugins for CDAP

Language: Java - Size: 4.04 MB - Last synced at: about 1 year ago - Pushed at: over 4 years ago - Stars: 11 - Forks: 15

data-integrations/dynamic-schema-sinks 📦

Dynamic schema based sinks

Language: Java - Size: 101 KB - Last synced at: about 1 year ago - Pushed at: almost 3 years ago - Stars: 5 - Forks: 2

data-integrations/azure

File Source to read data from distributed file system

Language: Java - Size: 249 KB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 4 - Forks: 5

data-integrations/argument-setter

A argument setter plugin

Language: Java - Size: 59.6 KB - Last synced at: 2 months ago - Pushed at: 2 months ago - Stars: 4 - Forks: 3

data-integrations/kafka-plugins

Kafka Source/Sink for reading/writing to kafka topic

Language: Java - Size: 1.38 MB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 3 - Forks: 22

data-integrations/amazon-s3-plugins

Amazon S3 source and sink

Language: Java - Size: 313 KB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 3 - Forks: 17

data-integrations/add-field

Plugin that adds a new field with a configurable value or UUID

Language: Java - Size: 38.1 KB - Last synced at: about 1 year ago - Pushed at: about 2 years ago - Stars: 3 - Forks: 6

data-integrations/google-analytics-360

A collection of Google Analytics 360 connectors and plugins.

Language: Java - Size: 68.4 KB - Last synced at: about 1 year ago - Pushed at: about 2 years ago - Stars: 3 - Forks: 4

data-integrations/hive-plugins

Hive Export/Import plugins

Language: Java - Size: 549 KB - Last synced at: about 1 year ago - Pushed at: about 2 years ago - Stars: 3 - Forks: 2

data-integrations/dynamic-spark

Dynamic Spark CDAP Plugins

Language: Java - Size: 167 KB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 2 - Forks: 14

data-integrations/sftp-actions

Language: Java - Size: 71.3 KB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 2 - Forks: 7

data-integrations/loaddatatosnowflake-action

Load data files from internal/external(amazon S3) location to Snowflake table.

Language: Java - Size: 47.9 KB - Last synced at: about 1 year ago - Pushed at: over 1 year ago - Stars: 2 - Forks: 2

data-integrations/kinesis-spark-streaming-source

Kinesis Spark Streaming Source Plugin: For ingesting data from Kinesis streams

Language: Java - Size: 69.3 KB - Last synced at: about 1 year ago - Pushed at: over 1 year ago - Stars: 2 - Forks: 1

data-integrations/google-ads

Collection of Google Ads connectors and plugins

Language: Java - Size: 156 KB - Last synced at: about 1 year ago - Pushed at: about 2 years ago - Stars: 2 - Forks: 4

data-integrations/vertica-bulk-import

Vertica Bulk Load: For bulk loading data into vertica

Language: Java - Size: 847 KB - Last synced at: about 1 year ago - Pushed at: about 2 years ago - Stars: 2 - Forks: 3

data-integrations/ftp-copy-action

Action plugin for copying data from a FTP/SFTP locations

Language: Java - Size: 61.5 KB - Last synced at: about 1 year ago - Pushed at: about 2 years ago - Stars: 2 - Forks: 2

data-integrations/multiple-file-sink

Language: Java - Size: 91.8 KB - Last synced at: about 1 year ago - Pushed at: about 2 years ago - Stars: 2 - Forks: 4

data-integrations/whole-file-ingest

Whole File Ingest and preserve file boundaries (Moving / Copying files)

Language: Java - Size: 128 KB - Last synced at: about 1 year ago - Pushed at: over 3 years ago - Stars: 2 - Forks: 5

data-integrations/http

Sink plugin to send the messages from the pipeline to an external http endpoint

Language: Java - Size: 467 KB - Last synced at: 14 days ago - Pushed at: 14 days ago - Stars: 1 - Forks: 29

data-integrations/elasticsearch-plugins

CDAP plugins to read from and write to Elasticsearch in batch and realtime

Language: Java - Size: 105 KB - Last synced at: 17 days ago - Pushed at: 17 days ago - Stars: 1 - Forks: 9

data-integrations/condition-plugins

A control flow plugin for making decisions based on runtime arguments and tokens

Language: Java - Size: 298 KB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 1 - Forks: 8

data-integrations/facebook

A collection of facebook connectors and plugins

Language: Java - Size: 127 KB - Last synced at: about 1 year ago - Pushed at: over 1 year ago - Stars: 1 - Forks: 4

data-integrations/file-appender

A HDFS File Appender Sink

Language: Java - Size: 41 KB - Last synced at: about 1 year ago - Pushed at: about 2 years ago - Stars: 1 - Forks: 2

data-integrations/date-transform

Date Transform Plugin

Language: Java - Size: 50.8 KB - Last synced at: about 1 year ago - Pushed at: about 2 years ago - Stars: 1 - Forks: 4

data-integrations/example-notification

Example Notification - Post Run Action

Language: Java - Size: 25.4 KB - Last synced at: about 1 year ago - Pushed at: about 2 years ago - Stars: 1 - Forks: 3

data-integrations/github

A collection of Github connectors and plugins

Language: Java - Size: 61.5 KB - Last synced at: about 1 year ago - Pushed at: about 2 years ago - Stars: 1 - Forks: 4

data-integrations/sap

Collection of SAP pluginis

Language: Java - Size: 104 KB - Last synced at: about 1 year ago - Pushed at: about 2 years ago - Stars: 1 - Forks: 7

thotasrinath/janus-plugins

Cdap Plugin to ingest data to JanusGraph.

Language: Java - Size: 5.3 MB - Last synced at: almost 2 years ago - Pushed at: about 2 years ago - Stars: 1 - Forks: 0

data-integrations/failpipeline-sink

Language: Java - Size: 43 KB - Last synced at: about 1 year ago - Pushed at: over 2 years ago - Stars: 1 - Forks: 3

data-integrations/kinesis-sink 📦

Kinesis Batch Sink Plugin

Language: Java - Size: 64.5 KB - Last synced at: about 1 year ago - Pushed at: over 2 years ago - Stars: 1 - Forks: 1

data-integrations/pdf-extractor-transform

Extracts content and metadata from a PDF using the Apache PDFBox library

Language: Java - Size: 2.47 MB - Last synced at: about 1 year ago - Pushed at: over 2 years ago - Stars: 1 - Forks: 2

data-integrations/redshifttos3-action 📦

Unloads the result of a query for redshift to one or more files on Amazon Simple Storage Service (Amazon S3).

Language: Java - Size: 55.7 KB - Last synced at: about 1 year ago - Pushed at: over 2 years ago - Stars: 1 - Forks: 1

data-integrations/kudu 📦

Kudu Source & Sink Plugin: For ingesting and writing data to and from Apache Kudu tables.

Language: Java - Size: 1.07 MB - Last synced at: about 1 year ago - Pushed at: over 5 years ago - Stars: 1 - Forks: 2

data-integrations/mqtt

MQTT Broker ingestion.

Language: Java - Size: 40 KB - Last synced at: about 1 year ago - Pushed at: over 5 years ago - Stars: 1 - Forks: 2

data-integrations/example-sparkcompute 📦

Spark Compute Example Plugin

Language: Java - Size: 22.5 KB - Last synced at: about 1 year ago - Pushed at: about 6 years ago - Stars: 1 - Forks: 2

data-integrations/tokenizer-analytics 📦

Tokenizer Analytics Plugin: A transform plugin to split data based on a pattern

Language: Java - Size: 37.1 KB - Last synced at: about 1 year ago - Pushed at: about 6 years ago - Stars: 1 - Forks: 2

data-integrations/logistic-regression-analytics 📦

Logistic Regression Predictor and Classifier Plugins

Language: Java - Size: 34.2 KB - Last synced at: about 1 year ago - Pushed at: over 7 years ago - Stars: 1 - Forks: 2

data-integrations/zendesk

A collection of Zendesk connector and plugin

Language: Java - Size: 163 KB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 0 - Forks: 8

data-integrations/multi-table-plugins

Pipeline plugins that allow reading from multiple DB tables with the same source

Language: Java - Size: 214 KB - Last synced at: 6 months ago - Pushed at: 6 months ago - Stars: 0 - Forks: 10

data-integrations/decompress-action

An action plugin for decompressing data before processing it. Useful for working with unsplittable formats.

Language: Java - Size: 130 KB - Last synced at: 11 months ago - Pushed at: 11 months ago - Stars: 0 - Forks: 3

data-integrations/repartitioner

Repartitions a spark RDD

Language: Java - Size: 69.3 KB - Last synced at: about 1 year ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 2

data-integrations/confluent

A collection of Confluent and Confluent Cloud

Language: Java - Size: 96.7 KB - Last synced at: about 1 year ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 5

data-integrations/oracle-export-action

Oracle Export Plugin

Language: Java - Size: 61.5 KB - Last synced at: about 1 year ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 2

data-integrations/cloud-vision

A collection of GCP Cloud Vision plugins

Language: Java - Size: 3.76 MB - Last synced at: about 1 year ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 6

data-integrations/sendgrid

A collection of sendgrid plugins

Language: Java - Size: 146 KB - Last synced at: about 1 year ago - Pushed at: about 2 years ago - Stars: 0 - Forks: 4

data-integrations/state-restore-action

State Store Action for tracking the states

Language: Java - Size: 39.1 KB - Last synced at: about 1 year ago - Pushed at: about 2 years ago - Stars: 0 - Forks: 2

data-integrations/vertica-bulk-export

Vertica Bulk Export

Language: Java - Size: 743 KB - Last synced at: about 1 year ago - Pushed at: about 2 years ago - Stars: 0 - Forks: 2

data-integrations/record-splitter-transform

Given a field and a delimiter, this splits the value into multiple records.

Language: Java - Size: 41 KB - Last synced at: about 1 year ago - Pushed at: about 2 years ago - Stars: 0 - Forks: 7

data-integrations/mixpanel

A collection of Mixpanel connectors and plugins

Language: Java - Size: 62.5 KB - Last synced at: about 1 year ago - Pushed at: about 2 years ago - Stars: 0 - Forks: 2

data-integrations/xml-directives

Collection of XML directives

Language: Java - Size: 995 KB - Last synced at: about 1 year ago - Pushed at: about 2 years ago - Stars: 0 - Forks: 1

data-integrations/data-profiler

Profiles the fields to generate statistics on each column specified.

Language: Java - Size: 64.5 KB - Last synced at: about 1 year ago - Pushed at: about 2 years ago - Stars: 0 - Forks: 1

data-integrations/splunk

A collection of Splunk connectors and plugins

Language: Java - Size: 144 KB - Last synced at: about 1 year ago - Pushed at: about 2 years ago - Stars: 0 - Forks: 4

data-integrations/topn

Aggregate plugin that computes top N

Language: Java - Size: 69.3 KB - Last synced at: about 1 year ago - Pushed at: about 2 years ago - Stars: 0 - Forks: 3

data-integrations/trash

Trash sink that eats up all the records passed to it.

Language: Java - Size: 42 KB - Last synced at: about 1 year ago - Pushed at: about 2 years ago - Stars: 0 - Forks: 1

data-integrations/zuora

A collection of Zuroa connector and plugins

Language: Java - Size: 1.02 MB - Last synced at: about 1 year ago - Pushed at: about 2 years ago - Stars: 0 - Forks: 4

data-integrations/amazon-s3client-action

An action plugin to work with S3 buckets and Objects

Language: Java - Size: 40 KB - Last synced at: about 1 year ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 2

data-integrations/azure-decompress-action

A CDAP pipeline action to decompress files from a container on Azure Blob Storage Blob service into another container.

Language: Java - Size: 94.7 KB - Last synced at: about 1 year ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 1

data-integrations/azure-delete-action

delete entity from Azure Blob service

Language: Java - Size: 79.1 KB - Last synced at: about 1 year ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 1

data-integrations/azure-face-transform

A plugin to extract the faces in a given set of images using Azure Cognitive APIs.

Language: Java - Size: 10.6 MB - Last synced at: about 1 year ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 3

data-integrations/fast-filter-transform

A filter that only allows records through that pass the specified criteria.

Language: Java - Size: 33.2 KB - Last synced at: about 1 year ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 2

data-integrations/file-contents-action 📦

An action plugin for checking for empty files as well as if a file has specific data in it.

Language: Java - Size: 96.7 KB - Last synced at: about 1 year ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 2

data-integrations/httptohdfs-action

Action Plugin: Fetches data from an external HTTP webservice or URL

Language: Java - Size: 53.7 KB - Last synced at: about 1 year ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 3

data-integrations/run-transform 📦

Run Transform Plugin: Runs an executable binary, installed on the local filesystem of Hadoop nodes

Language: Java - Size: 71.3 KB - Last synced at: about 1 year ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 2

data-integrations/s3toredshift-action

Loads the data from S3 into Redshift

Language: Java - Size: 43.9 KB - Last synced at: about 1 year ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 1

data-integrations/sampling-aggregator

Language: Java - Size: 46.9 KB - Last synced at: about 1 year ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 2

data-integrations/couchbase 📦

A collection of Couchbase plugins and connectors

Language: Java - Size: 66.4 KB - Last synced at: about 1 year ago - Pushed at: almost 3 years ago - Stars: 0 - Forks: 4

data-integrations/pubnub 📦

A collection of connectors to PubNub

Language: Java - Size: 114 KB - Last synced at: about 1 year ago - Pushed at: almost 3 years ago - Stars: 0 - Forks: 2

predictiveworks/cdap-graph

CDAP plugins to use JanusGraph as data source and sink with CDAP data pipelines

Language: Java - Size: 20.5 KB - Last synced at: about 2 years ago - Pushed at: about 3 years ago - Stars: 0 - Forks: 0

data-integrations/dynamodb-sink

Plugin to write data to DynamoDB.

Language: Java - Size: 63.5 KB - Last synced at: about 1 year ago - Pushed at: about 3 years ago - Stars: 0 - Forks: 2

data-integrations/file 📦

CDAP Plugins for reading from and writing data to HDFS compatible file systems

Language: Java - Size: 44.9 KB - Last synced at: about 1 year ago - Pushed at: about 3 years ago - Stars: 0 - Forks: 1

data-integrations/orientdb 📦

Sink to write to OrientDB

Language: Java - Size: 28.3 KB - Last synced at: about 1 year ago - Pushed at: about 3 years ago - Stars: 0 - Forks: 2

data-integrations/file-merge 📦

File merge action to merge files in HDFS or local filesystem

Language: Java - Size: 49.8 KB - Last synced at: about 1 year ago - Pushed at: about 3 years ago - Stars: 0 - Forks: 3

data-integrations/whole-file-reader 📦

Whole File Reader for reading entire file from HDFS.

Language: Java - Size: 38.1 KB - Last synced at: about 1 year ago - Pushed at: about 3 years ago - Stars: 0 - Forks: 2

data-integrations/dynamodb-source

DynamoDB Source Plugin: Reads from AWS DynamoDB tables

Language: Java - Size: 67.4 KB - Last synced at: about 1 year ago - Pushed at: about 3 years ago - Stars: 0 - Forks: 3

data-integrations/to-utf8-action

An action plugin to convert files created in other character sets into UTF-8 format

Language: Java - Size: 157 KB - Last synced at: about 1 year ago - Pushed at: about 3 years ago - Stars: 0 - Forks: 2

data-integrations/table-streaming-source 📦

Table StreamingSource Hydrator plugin

Language: Java - Size: 36.1 KB - Last synced at: about 1 year ago - Pushed at: about 3 years ago - Stars: 0 - Forks: 2

data-integrations/azure-event-hub 📦

Azure Event Hub Spark Streaming source to read events from an event bus

Language: Java - Size: 134 KB - Last synced at: about 1 year ago - Pushed at: about 4 years ago - Stars: 0 - Forks: 2

data-integrations/ngram-analytics 📦

NGram Analytics Transform Plugin: Transforms input features into n-grams

Language: Java - Size: 50.8 KB - Last synced at: about 1 year ago - Pushed at: over 4 years ago - Stars: 0 - Forks: 2

data-integrations/lookup 📦

A plugin for performing look ups for resource in GCS, BigQuery, BigTable, S3 or others

Size: 4.88 KB - Last synced at: about 1 year ago - Pushed at: over 5 years ago - Stars: 0 - Forks: 1

data-integrations/naive-bayes-analytics 📦

Naive Bayes Analytics Plugins: NaiveBayesTrainer and NaiveBayesClassifier plugins

Language: Java - Size: 44.9 KB - Last synced at: about 1 year ago - Pushed at: over 5 years ago - Stars: 0 - Forks: 1

data-integrations/segment 📦

A collection of segment connectors and plugins

Size: 4.88 KB - Last synced at: about 1 year ago - Pushed at: over 5 years ago - Stars: 0 - Forks: 1

data-integrations/skipgram-analytics 📦

SkipGram Feature Generator: Generates text-based features using Spark's Word2Vec.

Language: Java - Size: 37.1 KB - Last synced at: about 1 year ago - Pushed at: about 6 years ago - Stars: 0 - Forks: 1

data-integrations/dynamic-partitioner 📦

CDAP Plugins for Sinks that allow you to specify a list of fields, and leverage the values as partitions in the dataset.

Language: Java - Size: 123 KB - Last synced at: about 1 year ago - Pushed at: about 6 years ago - Stars: 0 - Forks: 2

data-integrations/example-action

This example action plugin can be used as a starting point for developing new Action plugins.

Language: Java - Size: 17.6 KB - Last synced at: about 1 year ago - Pushed at: about 6 years ago - Stars: 0 - Forks: 5

data-integrations/example-streamingsource 📦

Stream Source Example Plugin

Language: Java - Size: 12.7 KB - Last synced at: about 1 year ago - Pushed at: about 6 years ago - Stars: 0 - Forks: 1

data-integrations/decision-tree-analytics 📦

CDAP plugins for training a model using decision tree and for predicting outcomes based on the trained model.

Language: Java - Size: 67.4 KB - Last synced at: about 1 year ago - Pushed at: about 6 years ago - Stars: 0 - Forks: 1

data-integrations/mapr-plugins 📦

Plugins to read from and write to MapR specific components.

Language: Java - Size: 47.9 KB - Last synced at: about 1 year ago - Pushed at: about 6 years ago - Stars: 0 - Forks: 1

data-integrations/omniture 📦

Omniture plugins

Size: 4.88 KB - Last synced at: about 1 year ago - Pushed at: about 6 years ago - Stars: 0 - Forks: 1

nitinmotgi/salesforce

A collection of salesforce plugins

Size: 104 KB - Last synced at: about 2 years ago - Pushed at: about 6 years ago - Stars: 0 - Forks: 2

data-integrations/realtime-stream-source 📦

Realtime Stream Source Plugin: A Spark streaming source

Language: Java - Size: 62.5 KB - Last synced at: about 1 year ago - Pushed at: over 6 years ago - Stars: 0 - Forks: 4

data-integrations/phoenix-plugins 📦

[WIP] Apache Phoenix Data Source and Sink

Language: Java - Size: 69.3 KB - Last synced at: about 1 year ago - Pushed at: almost 7 years ago - Stars: 0 - Forks: 1

data-integrations/example-sparksink 📦

Spark Sink Example Plugin: Template for a Spark-based analytics plugin

Size: 5.86 KB - Last synced at: about 1 year ago - Pushed at: over 7 years ago - Stars: 0 - Forks: 1

data-integrations/hashing-tf-feature-generator 📦

Hashing TF Feature Generator Plugin

Language: Java - Size: 31.3 KB - Last synced at: about 1 year ago - Pushed at: over 7 years ago - Stars: 0 - Forks: 2

data-integrations/time-directives 📦

Collection of time directives

Size: 4.88 KB - Last synced at: about 1 year ago - Pushed at: over 7 years ago - Stars: 0 - Forks: 1

data-integrations/badges 📦

Collection of CDAP Github Badges

Size: 9.77 KB - Last synced at: about 1 year ago - Pushed at: about 8 years ago - Stars: 0 - Forks: 1

data-integrations/notify-pipeline 📦

Trigger processing of other pipelines

Size: 3.91 KB - Last synced at: about 1 year ago - Pushed at: about 8 years ago - Stars: 0 - Forks: 1