Re: Beam support Flink Async I/O operator

2021-01-27 Thread Eleanore Jin
[2] > https://beam.apache.org/documentation/transforms/java/aggregation/groupintobatches/ > > On 26 Jan 2021, at 22:09, Boyuan Zhang wrote: > > +dev > > On Tue, Jan 26, 2021 at 1:07 PM Eleanore Jin > wrote: > >> Hi community, >> >> Does Beam support F

Re: Beam support Flink Async I/O operator

2021-01-27 Thread Alexey Romanenko
ote: > > +dev <mailto:d...@beam.apache.org> > > On Tue, Jan 26, 2021 at 1:07 PM Eleanore Jin <mailto:eleanore@gmail.com>> wrote: > Hi community, > > Does Beam support Flink Async I/O operator? if so, can you please share the > doc, and if not, is t

Re: Beam support Flink Async I/O operator

2021-01-26 Thread Boyuan Zhang
+dev On Tue, Jan 26, 2021 at 1:07 PM Eleanore Jin wrote: > Hi community, > > Does Beam support Flink Async I/O operator? if so, can you please share > the doc, and if not, is there any workaround to achieve the same in Beam > semantics? > > > https://ci.apache.org/p

Beam support Flink Async I/O operator

2021-01-26 Thread Eleanore Jin
Hi community, Does Beam support Flink Async I/O operator? if so, can you please share the doc, and if not, is there any workaround to achieve the same in Beam semantics? https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/operators/asyncio.html https://cwiki.apache.org/confluence