jeoffreylim / maelstromLinks
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 8 years ago
Alternatives and similar repositories for maelstrom
Users that are interested in maelstrom are comparing it to the libraries listed below
Sorting:
- Flink Examples☆39Updated 9 years ago
- Spooker is a dynamic framework for processing high volume data streams via processing pipelines☆30Updated 9 years ago
- Collection of generic Apache Flink operators☆17Updated 8 years ago
- A High Performance Cluster Consumer for Kafka that creates Avro (boom) files in Hadoop in time based directory paths☆42Updated 9 years ago
- Flink performance tests☆28Updated 5 years ago
- A library for financial and time series calculations on Apache Spark☆28Updated 9 years ago
- Schema Registry integration for Apache Spark☆40Updated 2 years ago
- spark structured streaming via HTTP communication☆18Updated 3 years ago
- Yet Another Spark SQL JDBC/ODBC server based on the PostgreSQL V3 protocol☆34Updated 2 years ago
- Very fast & efficient grep for Kafka stream☆41Updated 9 years ago
- UberScriptQuery, a SQL-like DSL to make writing Spark jobs super easy☆61Updated last year
- ☆26Updated 5 years ago
- A light Kafka to HDFS/S3 ETL library based on Apache Spark☆41Updated 8 years ago
- Cascading on Apache Flink®☆54Updated last year
- Common utilities for Apache Kafka☆36Updated last year
- Streaming Analytics platform, built with Apache Flink and Kafka☆35Updated last year
- a smart, automated non-intrusive driver for hbase region-level major-compact☆8Updated 9 years ago
- High performance HBase / Spark SQL engine☆28Updated 3 years ago
- An example of using Flink for Fault-Tolerant Stream Processing☆12Updated 6 years ago
- A distributed generic query layer for Apache Kafka Interactive Queries☆26Updated 7 years ago
- A library for strong, schema based conversion between 'natural' JSON documents and Avro☆18Updated last year
- HDFS compatible Distributed Filesystem backed Cassandra☆25Updated 9 years ago
- A set of tools to ease working with Zookeeper and Kafka.☆23Updated 9 years ago
- Camus Compressor merges files created by Camus and saves them in a compressed format.☆13Updated 2 years ago
- Code examples for my blog posts☆22Updated 6 years ago
- Starter project for building MemSQL Streamliner Pipelines☆32Updated 8 years ago
- SamzaSQL: Streaming SQL implementation on top of Apache Samza and Apache Kafka☆29Updated 9 years ago
- Example using Grafana with Druid☆11Updated 10 years ago
- Spark CEP is an extension of Spark Streaming to support SQL-based query processing☆56Updated 8 years ago
- Sql interface to druid.☆77Updated 9 years ago