You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Королькевич Михаил <mk...@yandex.ru> on 2021/12/16 11:45:48 UTC
pyFlink + asyncio
Hi team!
<https://nightlies.apache.org/flink/flink-docs-
master/docs/dev/datastream/operators/asyncio/>
Is it possible to use this for pyFlink?
Or another asynchronous enrichment of an unordered data stream?
Re: pyFlink + asyncio
Posted by Alexander Preuß <al...@ververica.com>.
Hi Михаил,
From looking at
https://nightlies.apache.org/flink/flink-docs-master/api/python//pyflink.datastream.html
there is currently no AsyncFunction / RichAsyncFunction implementation in
pyFlink, so you are bound to synchronously interacting.
Best regards,
Alexander
On Thu, Dec 16, 2021 at 12:47 PM Королькевич Михаил <mk...@yandex.ru>
wrote:
> Hi team!
>
> https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/operators/asyncio/
> Is it possible to use this for pyFlink?
> Or another asynchronous enrichment of an unordered data stream?
>
--
Alexander Preuß | Junior Engineer - Data Intensive Systems
alexanderpreuss@ververica.com
<https://www.ververica.com/>
Follow us @VervericaData
--
Join Flink Forward <https://flink-forward.org/> - The Apache Flink
Conference
Stream Processing | Event Driven | Real Time
--
Ververica GmbH | Invalidenstrasse 115, 10115 Berlin, Germany
--
Ververica GmbH
Registered at Amtsgericht Charlottenburg: HRB 158244 B
Managing Directors: Karl Anton Wehner, Holger Temme, Yip Park Tung Jason,
Jinwei (Kevin) Zhang