Number of partitions, number of messages per partition

Derive case classes from data frames: use the schema to generate code

How to deploy a Spark job on Kubernetes (minikube)