Mongodb_sink

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

Mongodb_sink

dinesh
Hello all,

Can we implement TwoPhaseCommitProtocol for mongodb to get EXACTLY_ONCE semantics. Will there be any limitation for it?


Thanks,
Dinesh.
Reply | Threaded
Open this post in threaded view
|

Re: Mongodb_sink

lec ssmi
First of all, mongodb itself does not support transactions. But you can init a buffer to save  each row when  transaction begins, and save all the buffered records to database  once  when  transaction completes. 

C DINESH <[hidden email]> 于2020年7月15日周三 上午9:28写道:
Hello all,

Can we implement TwoPhaseCommitProtocol for mongodb to get EXACTLY_ONCE semantics. Will there be any limitation for it?


Thanks,
Dinesh.