Questions that
actually get asked.

How does Spark handle data skew in a join operation?

Explain Kafka log compaction and when you'd use it.

Difference between repartition() and coalesce()?

Design a Lambda architecture for a real-time dashboard.

Explain Scala implicits with a practical DE use case.

What is consumer group lag and how do you monitor it?

What is a broadcast variable in Spark and when do you use it?

Explain Window functions and give an example.