Я просматриваю кодовую базу Apache Flink и не могу понять ее.
Все задания запускаются, когда мы выполняем StreamExecutionEnvironment.get..().execute(), поэтому я просматриваю код RemoteStreamEnvironment, в частности функции execute.Я не могу понять, где в кодовой базе происходит фактическое распределение потоковых событий и роль RPC.В основном я пытаюсь понять, как в коде работает обработка распределенного потока.
Может кто-нибудь указать мне на некоторые базовые классы из кодовой базы и объяснить распределенную обработку?