Yelp / data_pipeline
Data Pipeline Clientlib provides an interface to tail and publish to data pipeline topics.
☆109Updated 2 years ago
Related projects ⓘ
Alternatives and complementary repositories for data_pipeline
- A schema store service that tracks and manages all the schemas used in the Data Pipeline☆86Updated 3 years ago
- An extension of the kafka-python package that adds features like multiprocess consumers.☆38Updated last year
- Provides a Pythonic interface for reading and writing Avro schemas☆26Updated 2 years ago
- Lightweight Azkaban client☆77Updated 4 years ago
- ReAir is a collection of easy-to-use tools for replicating tables and partitions between Hive data warehouses.☆280Updated 5 years ago
- Real²time Exploratory Analytics on Large Datasets☆121Updated 4 years ago
- MySQL-like queries for Druid built on top of Plywood☆147Updated 5 years ago
- MySQLStreamer is a database change data capture and publish system.☆409Updated 2 years ago
- Extensions, custom & experimental panels☆52Updated 9 years ago
- A plugin to the Kafka Connect framework that replicates data from MySQL to Kafka☆97Updated 8 years ago
- Example for an airflow plugin☆49Updated 8 years ago
- PostgreSQL protocol gateway for Presto distributed SQL query engine☆292Updated last year
- Hive UDFs for funnel analysis☆84Updated last year
- Hannibal is tool to help monitor and maintain HBase-Clusters that are configured for manual splitting.☆172Updated 6 years ago
- INACTIVE: A PostgreSQL extension to produce messages to Apache Kafka.☆112Updated 9 years ago
- Sparkline BI Accelerator provides fast ad-hoc query capability over Logical Cubes. This has been folded into our SNAP Platform(http://bit…☆284Updated 6 years ago
- Tool for gathering blocks and replicas meta data from HDFS. It also builds a heat map showing how replicas are distributed along disks an…☆56Updated 7 years ago
- Deprecated - Check out MemSQL Pipelines instead!☆8Updated 7 years ago
- Ferry lets you define, run, and deploy big data applications on AWS, OpenStack, and your local machine using Docker☆252Updated 9 years ago
- Airflow workflow management platform chef cookbook.☆68Updated 5 years ago
- kafka-connect-s3 : Ingest data from Kafka to Object Stores(s3)☆95Updated 5 years ago
- A Directed Acyclic Graph task dependency scheduler designed to simplify complex distributed pipelines☆130Updated 6 years ago
- Quark is a data virtualization engine over analytic databases.☆99Updated 7 years ago
- Kafka sink connector for streaming messages to PostgreSQL☆91Updated 4 years ago
- PipelineDB extension for Kafka support☆61Updated 5 years ago
- Based off the design of SparkOnHBase. This Repo will support Spark, Spark Streaming, and Spark SQL integration with Kudu.☆51Updated 8 years ago