Hi all, I'm computing some counts in a Beam job and want to sink the results to a REST API via HTTP. For example, group incoming elements by a key, count by key, and then every minute write the count to an API which supports incremental updates.
Is this something that other people have done with Beam? I was unable to find any examples of an Http sink online. If I write my own custom sink to do this, is there anything to be wary of? Thanks for any advice, Josh
