Flink's AsycIO operator is useful for processing io-bound operations,
e.g. sending network requests. Like Luke mentioned, it is not available
in Beam.
-Max
On 07.07.20 22:11, Luke Cwik wrote:
Beam is a layer that sits on top of execution engines like Flink and
provides its own programming model thus native operators like Flink's
async IO operator are not exposed.
Most people use a DoFn to do all their IO and sometimes will compose it
with another transform such as GroupIntoBatches[1] to simplify their
implementation.
Why do you need async?
1:
https://beam.apache.org/documentation/transforms/java/aggregation/groupintobatches/
On Tue, Jul 7, 2020 at 11:03 AM Eleanore Jin <eleanore....@gmail.com
<mailto:eleanore....@gmail.com>> wrote:
Hi community,
I cannot find any documentation for Beam supporting Flink async IO
operator
(https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/operators/asyncio.html),
just wonder is this not supported right now?
Thanks a lot!
Eleanore