jeoffreylim / maelstrom
Maelstrom is an open source Kafka integration with Spark that is designed to be developer friendly, high performance (millisecond stream processing), scalable (consumes messges at Spark worker nodes), and is extremely reliable.
☆22Updated 7 years ago
Related projects: ⓘ
- A library for strong, schema based conversion between 'natural' JSON documents and Avro☆18Updated 6 months ago
- A High Performance Cluster Consumer for Kafka that creates Avro (boom) files in Hadoop in time based directory paths☆42Updated 8 years ago
- ☆26Updated 4 years ago
- Camus Compressor merges files created by Camus and saves them in a compressed format.☆12Updated last year
- Collection of generic Apache Flink operators☆17Updated 7 years ago
- Flink Examples☆39Updated 8 years ago
- ☆10Updated this week
- Spooker is a dynamic framework for processing high volume data streams via processing pipelines☆29Updated 8 years ago
- A distributed generic query layer for Apache Kafka Interactive Queries☆26Updated 6 years ago
- Apache Flink as a Cloudera Manager Service☆12Updated 8 years ago
- INACTIVE: A daemon to transfer syslog messages to Apache Kafka.☆24Updated 7 years ago
- Cascading on Apache Flink®☆54Updated 7 months ago
- Schema Registry integration for Apache Spark☆39Updated last year
- Common utilities for Apache Kafka☆36Updated last year
- Starter project for building MemSQL Streamliner Pipelines☆32Updated 7 years ago
- ☆10Updated 9 years ago
- a smart, automated non-intrusive driver for hbase region-level major-compact☆8Updated 8 years ago
- An example of using Flink for Fault-Tolerant Stream Processing☆11Updated 5 years ago
- A library for financial and time series calculations on Apache Spark☆28Updated 8 years ago
- Real-time analytics in Apache Flume☆52Updated 8 years ago
- Helpful user defined fuctions / table generating functions for Hive☆101Updated 8 years ago
- Read druid segments from hadoop☆11Updated 7 years ago
- Example using Grafana with Druid☆11Updated 9 years ago
- Redis search and indexing in Java☆15Updated 7 years ago
- Yet Another Spark SQL JDBC/ODBC server based on the PostgreSQL V3 protocol☆34Updated 2 years ago
- A set of tools to ease working with Zookeeper and Kafka.☆23Updated 8 years ago
- ☆20Updated 7 years ago
- Dropwizard Metrics reporter for Apache Spark☆28Updated 9 years ago
- Mirror of Apache DirectMemory☆53Updated 9 months ago
- ☆18Updated this week