Я пытаюсь написать код, который сначала выполняет объединение, а затем выполняет агрегацию...

Я использую потоковую передачу Spark для подключения к google pubsub и могу читать и распечатывать...