00-PRODUCER
Compute sessions in scala using flatMapGroupsWithState.
01-Delta-session-BRONZE
Save kafka events in a Delta Lake table and start analysis.
02-Delta-session-SILVER
Clean events and remove duplicate in the Silver layer.
03-Delta-session-GOLD
Compute sessions with applyInPandasWithState and upsert (MERGE) output to sessions table.
scala/03-Delta-session-GOLD-scala
Compute sessions in scala using flatMapGroupsWithState.