Hi Beam Users, I have a use-case where I need to check whether a Pcollection is empty or not. If it's not empty I need to write a message to a Pub/Sub topic. I am using the Python SDK and Dataflow to write and run my pipelines respectively. I searched but could not come across any concrete way on how to check whether a Pcollection is empty or not using Python and how to take action based on the check. Is there any way to implement this using Beam.
Thanks & Regards Rajnil Guha
