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: 3 months ago - Pushed at: 3 months ago - Stars: 4 - Forks: 5

data-integrations/cobol-to-avro-transform

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

data-integrations/amazon-s3-plugins

Amazon S3 source and sink

Language: Java - Size: 323 KB - Last synced at: 30 days ago - Pushed at: 30 days ago - Stars: 3 - Forks: 17

data-integrations/kafka-plugins

Kafka Source/Sink for reading/writing to kafka topic

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

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: over 2 years ago - Stars: 3 - Forks: 6

data-integrations/hive-plugins

Hive Export/Import plugins

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

data-integrations/dynamic-spark

Dynamic Spark CDAP Plugins

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

data-integrations/sftp-actions

Language: Java - Size: 71.3 KB - Last synced at: 4 months ago - Pushed at: 4 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: almost 2 years ago - Stars: 2 - Forks: 1

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: over 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: over 2 years ago - Stars: 2 - Forks: 2

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: almost 4 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: 4 days ago - Pushed at: 4 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: 112 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 1 - Forks: 9

data-integrations/file-appender

A HDFS File Appender Sink

Language: Java - Size: 41 KB - Last synced at: about 1 year ago - Pushed at: over 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: over 2 years ago - Stars: 1 - Forks: 4

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/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/multi-table-plugins

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

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

data-integrations/image-directives

A set of directives for working with images

Language: Java - Size: 1.33 MB - Last synced at: 9 months ago - Pushed at: 9 months ago - Stars: 0 - Forks: 1

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: about 1 year ago - Pushed at: about 1 year 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/oracle-export-action

Oracle Export Plugin

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

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: over 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: over 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: over 2 years ago - Stars: 0 - Forks: 7

data-integrations/xml-directives

Collection of XML directives

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

data-integrations/topn

Aggregate plugin that computes top N

Language: Java - Size: 69.3 KB - Last synced at: about 1 year ago - Pushed at: over 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: over 2 years ago - Stars: 0 - Forks: 1

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/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/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/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/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/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/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/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