Hurence / logisland
Scalable stream processing platform for advanced realtime analytics on top of Kafka and Spark. LogIsland also supports MQTT and Kafka Streams (Flink being in the roadmap). The platform does complex event processing and is suitable for time series analysis. A large set of valuable ready to use processors, data sources and sinks are available.
☆109Updated 11 months ago
Related projects: ⓘ
- RESTful Complex Event Processor powered by Kafka & Siddhi☆48Updated 5 months ago
- StreamLine - Streaming Analytics☆164Updated last year
- Sherlock is an anomaly detection service built on top of Druid☆152Updated last year
- A Real-Time Analytical Processing (RTAP) example using Spark/Shark☆51Updated 10 years ago
- AMQP data source for dstream (Spark Streaming)☆26Updated 2 years ago
- Mirror of Apache Lens☆60Updated 4 years ago
- Java event logs collector for hadoop and frameworks☆39Updated last month
- Cascading on Apache Flink®☆54Updated 7 months ago
- A utility for generating Oozie workflows from a YAML definition☆48Updated 5 years ago
- Apache MiNiFi (a subproject of Apache NiFi)☆123Updated 3 years ago
- Anomaly detection framework @ PayPal☆106Updated 5 years ago
- A spark package for loading Spark ML models to Redis-ML☆63Updated 5 years ago
- HopsWorks - Hadoop for Humans☆116Updated 5 years ago
- Continuous scalable web crawler built on top of Flink and crawler-commons☆51Updated 5 years ago
- Distributed, streaming anomaly detection and prediction with HTM in Apache Flink☆136Updated 7 years ago
- Extensions, custom & experimental panels☆52Updated 8 years ago
- ☆47Updated this week
- Real-time aggregation of metrics from large distributed systems.☆105Updated 5 years ago
- Ambari Service for OpenTSDB☆34Updated 7 years ago
- Flowmix is a flexible event processing engine for Apache Storm. It supports complex correlations of events via sliding/tumbling windows. …☆54Updated 8 years ago
- UberScriptQuery, a SQL-like DSL to make writing Spark jobs super easy☆59Updated 9 months ago
- flink-jpmml is a fresh-made library for dynamic real time machine learning predictions built on top of PMML standard models and Apache Fl…☆96Updated 5 years ago
- Anomaly Detection model uses Spark for training and Spark Streaming for testing☆66Updated 8 years ago
- Spooker is a dynamic framework for processing high volume data streams via processing pipelines☆29Updated 8 years ago
- An Integrated and collaborative cloud environment for building and running Spark applications on PKS/Kubernetes☆81Updated 4 years ago
- Big Data ETL and Utilities for Hadoop Map Reduce, Spark and Storm☆105Updated 7 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
- Very fast & efficient grep for Kafka stream☆40Updated 9 years ago
- Enabling Spark Optimization through Cross-stack Monitoring and Visualization☆47Updated 7 years ago
- ☆38Updated this week