An end-to-end real-time Big Data pipeline for hospital operations. Processes streaming admission/discharge data using Kafka, NiFi, and PySpark to provide live bed occupancy and ER wait time analytics in MySQL.
mysql kafka big-data apache-spark pyspark kafka-consumer apache-nifi nifi-processors nifi-custom-processor streaming-pipeline real-time-analytics-data-engineering
-
Updated
Feb 13, 2026 - Python