Sentiment Analysis of a Twitter Topic with Spark Structured Streaming

Streaming Synthetic Sales Data Generator: Streaming sales data generator for Apache Kafka, written in Python

An naive anomaly detection and data visualization tool for F1 on board telemetry data.

Spark Structured Streaming data pipeline that processes movie ratings data in real-time.

cpu anomaly detection with spark

This project provides an opinionated way to go about crafting Spark Structured Streaming applications with PySpark

A distributed streaming data processing pipeline.

Spark Examples

Streaming data pipeline using apache airflow, kafka , Minio object storage

Stream processing pipeline for analyzing live chat data

Kafka streaming job from iomete. This streaming job copies data from Kafka to Iceberg.

Simple datalake

Pyspark sample for upsert data to oracle table

A Log Analytics demo based on Spark Structured Streaming + Kafka

Twitter Web-App using Apache Kafka, Spark & perform analysis

Spark Structured Streaming with Kafka Integration

Twitter Streaming Project

Spark Structured Streaming vs Kafka Streams

Statistical analyses of San Francisco crime incidents using Apache Spark Structured Streaming

High Performance Computing Center