Hello! I have also been building a proof of concept(PR <https://github.com/apache/beam/pull/9199>), which implements the streaming wordcount example in the design doc.
What is missing in the PoC is ordering guarantee implementation in sink (which I am working on). -Rui On Wed, Jul 24, 2019 at 1:37 PM Rui Wang <ruw...@google.com> wrote: > Hello! > > In case you are not aware of, I have added a modified streaming wordcount > example at the end of the doc to illustrate retractions. > > > -Rui > > On Wed, Jul 10, 2019 at 10:58 AM Rui Wang <ruw...@google.com> wrote: > >> Hi Community, >> >> Retractions is a part of core Beam model [1]. I come up with a doc to >> discuss retractions about use cases, model and API (see the link below). >> This is a very beginning discussion on retractions but I do hope we can >> have a consensus and make retractions implemented in a useful way >> eventually. >> >> >> doc link: >> https://docs.google.com/document/d/14WRfxwk_iLUHGPty3C6ZenddPsp_d6jhmx0vuafXqmE/edit?usp=sharing >> >> >> [1]: https://issues.apache.org/jira/browse/BEAM-91 >> >> >> -Rui >> >
