spark-structured-streaming
Online latent state estimation with Spark
This project provides an opinionated way to go about crafting Spark Structured Streaming applications with PySpark