Hello!

I want to make HTTP(S) calls to enrich data streams. The HTTP services are
running on our VPC, so the delay is limited, but sometimes these services
end up calling third party APIs, and latencies become high.

>From documentation (
https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/dev/python/overview/)
it seems PyFlink does not support "asyncio operator" like Java does (
https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/dev/datastream/operators/asyncio/).
Am I missing something? How should this be approached?

Thanks!

--
Dhavan

Reply via email to