Подзапросы в PySpark через DataFrame API (PySpark subqueries DataFrame API) долго оставались слабым местом. Как только нужен коррелированный подзапрос (correlated subquery), приходилось регистрировать временные представления...