structured-streaming topic
spark-gdelt
Binding the GDELT universe in a Spark environment
recsys_structured_streaming
kafka + structured streaming + phoenix + elasticsearch 基于行为日志实现热门推荐,用户偏好推荐,召回融合策略实现。
financial-market-data-analysis
Real-Time Financial Market Data Processing and Prediction application
s3-sqs-connector
A library for reading data from Amzon S3 with optimised listing using Amazon SQS using Spark SQL Streaming ( or Structured streaming).
spark-state-store
Rocksdb state storage implementation for Structured Streaming.
streaminglens
Qubole Streaminglens tool for tuning Spark Structured Streaming Pipelines
spark-sql-kafka-offset-committer
Kafka offset committer for structured streaming query
spark-state-tools
Spark Structured Streaming State Tools
spark-structured-streaming-examples
Spark structured streaming examples with using of version 3.5.1
open-stream-processing-benchmark
This repository contains the code base for the Open Stream Processing Benchmark.