Каковы лучшие практики, когда http вызывает из DoFn в конвейере, который будет работать в облачном потоке данных Google?(Java)
Я имею в виду, если в чистой Java без использования Beam мне нужно подумать о таких вещах, как асинхронные вызовы или, по крайней мере, многопоточность.Подумайте об управлении пулом потоков, пулом соединений ... Что произойдет с потоком данных, если у меня будет только один поток, создающий синхронизирующий вызов в каждом ProcessElement?Как лучше всего выполнять http-звонки в DoFn?