Hi guys, I am working on an accumulation task with dataflow; I want to consume events from Pubsub and accumulate and insert them into Spanner. For inserting part I want to increment the value of the count column in my table; with DML I can do it as below:
"UPDATE MY_TABLE set COLUMN1 = COLUMN1 + newValue" but I don't know how can I do that with mutation (or with Beam Spanner API)! Could you please help me? Regards Hamed