Structured Streaming is a reference application showing how to easily integrate structured streaming Apache Spark Structured Streaming, Apache Cassandra and Apache Kafka for fast, structured streaming computations on data.
☆13Nov 17, 2018Updated 7 years ago
Alternatives and similar repositories for structured-streaming-application
Users that are interested in structured-streaming-application are comparing it to the libraries listed below
Sorting:
- Simple implementation of a custom parquet reader/writer☆11Aug 12, 2016Updated 9 years ago
- 一个Spring Security添加验证码的示例☆11Sep 3, 2017Updated 8 years ago
- Spark Structured Streaming / Kafka / Cassandra / Elastic☆186Feb 7, 2023Updated 3 years ago
- ☆12May 30, 2017Updated 8 years ago
- A Spark metrics sink that pushes to InfluxDb☆51Jan 14, 2021Updated 5 years ago
- ☆13May 11, 2018Updated 7 years ago
- Visualize customer insights with business data for product performance analysis☆10Sep 17, 2025Updated 6 months ago
- Spark Structured Streaming data pipeline that processes movie ratings data in real-time.☆13Mar 1, 2026Updated 2 weeks ago
- This is an activator project for showcasing how to read & write data from Kafka-cluster using Java Producer & Consumer API.☆11May 24, 2017Updated 8 years ago
- Spark + Jupyer + Hive☆16Sep 22, 2015Updated 10 years ago
- ☆11Apr 15, 2019Updated 6 years ago
- Race mapper for displaying participant progress and location - Kafka, KSQL, Kibana and MQTT based integration☆18Sep 23, 2019Updated 6 years ago
- ☆16Sep 17, 2017Updated 8 years ago
- A started draft of a typesafe - scala - compatible API☆20Nov 9, 2017Updated 8 years ago
- Reactive Play application with Slick extensions for PostgreSQL☆15Oct 18, 2015Updated 10 years ago
- 🔍使用elasticsearch的java api进行from&size和scroll分页操作。☆10Jun 17, 2022Updated 3 years ago
- A sink to save Spark Structured Streaming DataFrame into Hive table☆30Apr 16, 2018Updated 7 years ago
- Building Microservices with Spring Boot☆14May 7, 2015Updated 10 years ago
- An example on how to implement a very simple authentication and authorization mechanism with Akka HTTP. Related to https://blog.codecentr…☆22Jul 26, 2019Updated 6 years ago
- ☆16Jun 9, 2016Updated 9 years ago
- Connector between Spark and InfluxDB.☆23May 19, 2016Updated 9 years ago
- ☆75Jun 27, 2020Updated 5 years ago
- ☆14May 28, 2020Updated 5 years ago
- A typelevel.g8 based on sbt-typelevel☆15Updated this week
- ☆27Nov 22, 2023Updated 2 years ago
- Encapsulated spark 与其他组件的结合api，方便使用，例如 es，hbase，kudu，kafka，mq等☆35Dec 18, 2019Updated 6 years ago
- ☆26May 1, 2024Updated last year
- Spark Plugin for Amazon S3☆13Feb 3, 2016Updated 10 years ago
- ☆18May 9, 2019Updated 6 years ago
- An AI Library from Knoldus to the open source community☆16Dec 23, 2018Updated 7 years ago
- In-browser data analysis using SQL | Powered by duckdb-wasm☆26Dec 21, 2025Updated 2 months ago
- An example of Spark and GraphX with Twitter as sample☆19Dec 29, 2016Updated 9 years ago
- F# .net core web api template☆17Jul 8, 2019Updated 6 years ago
- A small project to allow publishing data to Apache Kafka, Apache Pulsar or any other target system☆15Sep 21, 2020Updated 5 years ago
- Model explanation provides the ability to interpret the effect of the predictors on the composition of an individual score.☆13Jan 21, 2021Updated 5 years ago
- ☆23Nov 15, 2018Updated 7 years ago
- Automated Mushroom Cultivation Environment with Raspberry Pi Model - 2 B☆12Jun 13, 2020Updated 5 years ago
- Real-time anomaly detection using Kafka, KSQL User Defined Function and a pre-trained model☆30Dec 16, 2023Updated 2 years ago
- Rocksdb state storage implementation for Structured Streaming.☆17Oct 21, 2020Updated 5 years ago