Какое правильное ограничение следует использовать для разбитого DoFn, считывающего неограниченную итерацию?
# #java #mongodb #google-cloud-dataflow #apache-beam Вопрос: Я пишу разделяемый DoFn для чтения потока изменений MongoDB. Это позволяет мне наблюдать события, описывающие изменения в коллекции, и я могу начать чтение с…