Kinesis Connector for Structured Streaming
-
Updated
Jul 2, 2024 - Scala
Kinesis Connector for Structured Streaming
Custom state store providers for Apache Spark
Extensible streaming ingestion pipeline on top of Apache Spark
Spark structured streaming examples with using of version 3.5.1
spark structured streaming via HTTP communication
Spark1.6和spark2.2的示例,包含kafka,flume,structuredstreaming,jedis,elasticsearch,mysql,dataframe
Real-time streaming data pipeline for Twitter Tweets
Samples for using Kafka within Spark Streaming and Akka Actors, Akka Streams
Analytics for IoT devices using Apache Spark Structured Streaming 2.4.0
Spark Structured Streaming with State Store
Online latent state estimation with Spark
Elastic scaling is a library that allows to control the number of resources (executors or workers) instantiated by a Spark Structured Streaming Job in order to optimize the effective microbatch duration.
Structured Streaming Log Analysis
Research on legacy and structured streaming with Spark
NYC Taxi & Limousine Commission's open data with Spark Streaming 3.0.0
Get up and running quickly with Spark Structured Streaming on Azure Databricks using Azure Event Hubs
Fork of the Apache Bahir sql-streaming-sqs, compatible with Spark 3
In-Stream final project
Add a description, image, and links to the spark-structured-streaming topic page so that developers can more easily learn about it.
To associate your repository with the spark-structured-streaming topic, visit your repo's landing page and select "manage topics."