Мы пытаемся создать приложение, используя BEAM в качестве нашего API преобразования. В настоящее время мы сталкиваемся с проблемой, и был бы признателен, если бы кто-то указал нам правильное направление.
Вот наш вариант использования.
1. Мы обрабатываем файл, который должен вызвать базу данных, а затем заменить значение ключом. Этот код работает нормально.
2. У нас есть некоторая бизнес-логика, в которой, если запрашивается кэширование, мы должны загрузить полный ключ / значения на карту и предоставить его PCollection. Вот где мы боремся.
Мы были бы очень признательны, если бы вы могли направить нас в правильном направлении.
Если это неправильный форум, сообщите нам, где мы можем разместить такие вопросы.
Спасибо