Large-scale Incremental Processing Using Distributed Transactions and Notifications Large-scale Incremental Processing Using Distributed Transactions and Notifications