Как реализовать переменную, аналогичную аккумуляторам Spark в Apache Beam
#apache-beam Вопрос: В настоящее время я использую Apache Beam 2.29.0 в Spark. Мой конвейер использует данные из Kafka, для которых у меня есть пользовательский клиент KafkaConsumer, который Beam создает посредством…