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
- ☆26Updated 5 years ago
- Yet Another Spark SQL JDBC/ODBC server based on the PostgreSQL V3 protocol☆34Updated 3 years ago
- Common utilities for Apache Kafka☆36Updated 2 years ago
- Cascading on Apache Flink®☆54Updated last year
- UberScriptQuery, a SQL-like DSL to make writing Spark jobs super easy☆63Updated last year
- Schema Registry integration for Apache Spark☆40Updated 2 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
- Collection of generic Apache Flink operators☆17Updated 8 years ago
- Spooker is a dynamic framework for processing high volume data streams via processing pipelines☆30Updated 9 years ago
- Flink performance tests☆28Updated 5 years ago
- Streaming Analytics platform, built with Apache Flink and Kafka☆34Updated 2 years ago
- spark structured streaming via HTTP communication☆18Updated 3 years ago
- Sql interface to druid.☆77Updated 9 years ago
- A library for financial and time series calculations on Apache Spark☆28Updated 9 years ago
- A library for strong, schema based conversion between 'natural' JSON documents and Avro☆18Updated last year
- Library and a Framework for building fast, scalable, fault-tolerant Data APIs based on Akka, Avro, ZooKeeper and Kafka☆25Updated 4 years ago
- Druid indexing plugin for using Spark in batch jobs☆101Updated 3 years ago
- JDBC driver that converts any INSERT, UPDATE and DELETE statements into append-only INSERTs. Instead of updating rows in-place it inserts…☆82Updated 8 years ago
- Euphoria is an open source Java API for creating unified big-data processing flows. It provides an engine independent programming model w…☆83Updated 2 years ago
- Post: Kafka - Rewind Consumer Offset☆23Updated 3 years ago
- Very fast & efficient grep for Kafka stream☆42Updated 10 years ago
- An example of using Flink for Fault-Tolerant Stream Processing☆12Updated 6 years ago
- spark + drools☆103Updated 3 years ago
- HDFS compatible Distributed Filesystem backed Cassandra☆25Updated 10 years ago
- Camus Compressor merges files created by Camus and saves them in a compressed format.☆13Updated 2 years ago
- ## Auto-archived due to inactivity. ## Simple JVM Profiler Using StatsD and Other Metrics Backends☆15Updated 2 years ago
- Mirror of Apache Lens☆62Updated 5 years ago
- SQL for Kafka Connectors☆99Updated last year
- A set of tools to ease working with Zookeeper and Kafka.☆23Updated 9 years ago