酷玩 Spark: Spark 源代码解析、Spark 类库等
-
Updated
May 18, 2022 - Scala
#
structured-streaming
Here are 103 public repositories matching this topic...
This is the github repo for Learning Spark: Lightning-Fast Data Analytics [2nd Edition]
-
Updated
Jan 28, 2025 - Scala
The Internals of Spark Structured Streaming
-
Updated
Nov 18, 2025
Enabling Continuous Data Processing with Apache Spark and Azure Event Hubs
microsoft streaming real-time scala kafka spark apache-spark stream connector azure bigdata apache spark-streaming eventhubs ingestion continuous event-hubs databricks structured-streaming
-
Updated
Feb 14, 2025 - Scala
Spark Structured Streaming / Kafka / Cassandra / Elastic
-
Updated
Feb 7, 2023 - Scala
Kinesis Connector for Structured Streaming
-
Updated
Jul 2, 2024 - Scala
Spark Connector to read and write with Pulsar
data-science spark apache-spark stream-processing flink data-processing batch-processing structured-streaming spark-sql apache-pulsar
-
Updated
Dec 5, 2025 - Scala
Real-Time Financial Market Data Processing and Prediction application
python apache-spark mariadb pytorch neural-networks scrapy apache-kafka financial-data structured-streaming
-
Updated
Jul 23, 2023 - Python
Custom state store providers for Apache Spark
spark apache-spark state apache spark-streaming stateful structured-streaming state-store spark-structured-streaming
-
Updated
Feb 14, 2025 - Scala
Use Kafka and Apache Spark streaming to perform click stream analytics
data-science kafka spark apache-spark jupyter-notebook structured-streaming clickstream ibmcode ibm-data-science-experience
-
Updated
Feb 29, 2020 - Jupyter Notebook
Astronomy Broker based on Apache Spark
-
Updated
Dec 23, 2025 - Python
This repository contains the code base for the Open Stream Processing Benchmark.
distributed-systems benchmark real-time kafka spark distributed-computing stream-processing spark-streaming flink kafka-streams benchmark-suite real-time-processing structured-streaming
-
Updated
Nov 23, 2021 - Jupyter Notebook
How to build your first Spark application with MLlib, StructuredStreaming, GraphFrames, Datasets and so on? Answer is here!
-
Updated
Nov 5, 2019 - Scala
Kafka offset committer for structured streaming query
-
Updated
Feb 15, 2021 - Scala
This repo contains examples of high throughput ingestion using Apache Spark and Apache Iceberg. These examples cover IoT and CDC scenarios using best practices. The code can be deployed into any Spark compatible engine like Amazon EMR Serverless or AWS Glue. A fully local developer environment is also provided.
-
Updated
Jul 2, 2025 - Java
Spark structured streaming examples with using of version 3.5.1
-
Updated
Apr 27, 2024 - Scala
A structured streaming was applied to the robot data from ROS-Gazebo simulation environment using Apache Spark. Data is collected in Kafka, analyzed by Apache Spark and stored in Cassandra.
python apache-spark cqlsh python3 ros pyspark spark-streaming kafka-consumer data-analysis apache-kafka kafka-producer apache-cassandra structured-streaming spark-sql spark-kafka-integration spark-cassandra-connector spark-cassandra ros-noetic spark-kafka-connector
-
Updated
Feb 6, 2022 - Python
Improve this page
Add a description, image, and links to the structured-streaming topic page so that developers can more easily learn about it.
Add this topic to your repo
To associate your repository with the structured-streaming topic, visit your repo's landing page and select "manage topics."