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

[Sunny, Mani Kolbe]

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