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> 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 >
