Custom state store providers for Apache Spark
Extensible streaming ingestion pipeline on top of Apache Spark
Online latent state estimation with Spark