Вся работа происходит внутри asyncInvoke из RichAsyncFunction. Итак, чтобы иметь возможность вызывать службу REST, вам нужно использовать асин * HTTP-клиент asyn c (технически это может быть синхронный клиент, но это не имеет смысла). Пример использования асин c http-клиента здесь .
Итак, когда вы выполняете асин c запрос, все, что вам нужно сделать, это позвонить resultFuture.complete в вашем обработчике запросов, так что результат передается по течению во Flink.