[jira] [Created] (BEAM-10489) Spanner ReaderWrite Transactions

["sailaxmankumar (Jira)" <ji...@apache.org>]

sailaxmankumar created BEAM-10489:
-------------------------------------

             Summary: Spanner ReaderWrite Transactions
                 Key: BEAM-10489
                 URL: https://issues.apache.org/jira/browse/BEAM-10489
             Project: Beam
          Issue Type: Wish
          Components: io-java-gcp
            Reporter: sailaxmankumar


We are currently using SpannerIO Mutations for writing Records to SpannerDB using both streaming and batch pipelines: 

However, as our business requirements need more logic on finding ability in beam spanner io to be able to handle readwrite transactions:

*Scenario 1:* We need to make sure that the data that gets processed in the pipeline and committed into Spanner to be always the latest data. Hence we need the capability to be able to read / query specific field eg Date or SequenceNumber to compare with before committing the updated record into Spanner. Eg. only commit a certain record when the current event’s sequenceNumber is greater than whats already in the Spanner row.

*Scenario 2:* We need to run end of the day batch pipelines which are trying to override the current data in spanner, but however if there is some latest data from streaming during the time of batch data write, we are unable to identify which is the last row as they are two different pipelines

*Scenario 3:* In a streaming pipeline if an event was delayed and processed at later time by adding to backlog queue, we would not want to perform an Spanner update query on this event where there is relatively new event to the spanner db already.

If SpannerIO has some capability to create readwrite transactions. It would help us to extend it to be utilised in these kind of solutions. 



Could you please help us extend spannerio for such scenarios



--
This message was sent by Atlassian Jira
(v8.3.4#803005)