This is an example of real time stream processing using Spark Streaming, Kafka & Elasticsearch.
☆40Aug 31, 2016Updated 9 years ago
Alternatives and similar repositories for real-time-stream-processing-engine
Users that are interested in real-time-stream-processing-engine are comparing it to the libraries listed below
Sorting:
- Tensor-based Spectral LDA on Spark☆18Jun 5, 2018Updated 7 years ago
- Scala HTTP/SOCKS proxy library, based on akka-streams☆10Nov 3, 2018Updated 7 years ago
- SQL for Redis☆11Sep 16, 2022Updated 3 years ago
- Implementation of a Big Data (batch and stream) distributed processing engine in Java using Akka actors.☆12Feb 20, 2023Updated 3 years ago
- 使用rocksDB实现LinkedList双向链表,可用于本地MQ队列，实现本地MQ等持久化存储。☆10Sep 11, 2018Updated 7 years ago
- Spark Structured Streaming / Kafka / Cassandra / Elastic☆186Feb 7, 2023Updated 3 years ago
- Build and run Spark Structured Streaming pipelines in Hadoop - project using PySpark.☆13Jun 6, 2019Updated 6 years ago
- This is a sample maven project setup for a mixed scala and java project.☆13Jan 3, 2023Updated 3 years ago
- Tweet Analysis with Spark☆14Aug 28, 2017Updated 8 years ago
- This project aims to make writing Spark applications easier by abstracting the effort to assemble the driver into reusable steps and pipe…☆16Feb 4, 2025Updated last year
- Streaming Analytics platform, built with Apache Flink and Kafka☆36Oct 6, 2023Updated 2 years ago
- This is an activator project providing a seed for starting with Play & Slick using AngularJS☆14May 24, 2017Updated 8 years ago
- ACL Management for Apache Spark SQL with Apache Ranger☆17Jun 18, 2020Updated 5 years ago
- Master complex big data processing, stream analytics, and machine learning with Apache Spark☆18Jan 30, 2023Updated 3 years ago
- Twitter sentiment analysis using Spark and Stanford CoreNLP and visualization using elasticsearch and kibana☆19Jan 28, 2018Updated 8 years ago
- ☆51Aug 13, 2015Updated 10 years ago
- Spark Structured Streaming JDBC Sink☆16Apr 26, 2021Updated 4 years ago
- learn calcite sql parsing☆18Sep 16, 2022Updated 3 years ago
- Flink dynamic CEP demo☆19Mar 22, 2022Updated 3 years ago
- An example of Spark and GraphX with Twitter as sample☆19Dec 29, 2016Updated 9 years ago
- ☆56Aug 21, 2014Updated 11 years ago
- conbine flume,spark-streaming and redis for real-time computing☆22Oct 20, 2014Updated 11 years ago
- Big data performance test analysis platform (including WebUI display)。 BigDataAnalysisWeb Analyze storm, spark, and flink throughput chan…☆20May 17, 2019Updated 6 years ago
- Cassandra Manager REST API & Web UI☆24Nov 29, 2017Updated 8 years ago
- Multi-stage, config driven, SQL based ETL framework using PySpark☆26Sep 16, 2019Updated 6 years ago
- Akka HTTP REST API Project Template using Akka HTTP 10.0.4 with Circe 0.7.0 targeting Scala 2.12.x☆20Mar 17, 2017Updated 8 years ago
- API proxy gateway base on netty and okHttp.☆22Aug 6, 2018Updated 7 years ago
- Use Scala API to read/write data from different databases,HBase,MySQL,etc.☆24Feb 28, 2018Updated 8 years ago
- Network storage and analytics library☆27Jun 21, 2017Updated 8 years ago
- A persistent queue based on RocksDB☆26Dec 5, 2023Updated 2 years ago
- ☆63Nov 8, 2019Updated 6 years ago
- Introductory sample scala app using Apache Spark Streaming to accept data from Kafka and write a summary to Cassandra.☆22Dec 5, 2018Updated 7 years ago
- Java task scheduler to execute threads which dependency is managed by directed acyclic graph☆25Feb 2, 2017Updated 9 years ago
- Spark structured streaming with Kafka data source and writing to Cassandra☆63Dec 5, 2019Updated 6 years ago
- A set of tools that make working with the Scala ecosystem even better.☆12Updated this week
- This is an activator project providing a seed for starting with Play & Slick, how to write unit test and how to use mocking for unit test…☆27Sep 4, 2017Updated 8 years ago
- Spark—Python学习笔记☆11Sep 25, 2018Updated 7 years ago
- Hands-On Deep Learning with Apache Spark, Published by Packt☆31Apr 17, 2023Updated 2 years ago
- spring-boot利用scala写spark程序骨架☆28Oct 22, 2019Updated 6 years ago