Thanks a lot. it solved my issue.
On Wed, Apr 27, 2022 at 3:19 PM Jan Lukavský wrote:
> Hi Sigalit,
>
> if I understand correctly, what you want is a deduplication of outputs
> coming from your GBK logic, is that correct? If do, you can use a
> stateful DoFn and a ValueState holding the last val
Hi Sigalit,
if I understand correctly, what you want is a deduplication of outputs
coming from your GBK logic, is that correct? If do, you can use a
stateful DoFn and a ValueState holding the last value seen per key in
global window. There is an implementation of this approach in
Deduplicate.
