Re: Apply Wait.on() pattern after AvroIO, KinesisIO writes

[Mani Kolbe]

I am using sparkRunner on streaming mode. So stateful DoFn is not
supported.

On Sat, 27 Jun, 2020, 7:48 AM Sunny, Mani Kolbe, <sun...@dnb.com> wrote:

> Hello,
>
>
>
> I am looking to implement Wait.on() pattern to do something after writes
> for each window are done. There are two outputs - one writing using AvroIO
> and other using KinesisIO.   The problem is writes don’t return PCollection
> which is required to construct Wait.On(). Is there a way around?
>
>
>
> Regards,
>
> Mani
>