ajothomas opened a new pull request #1560:
URL: https://github.com/apache/samza/pull/1560


   **Feature**:
   Samza Table API currently supports PUT, GET and DELETE. Puts typically 
write/overwrite the data for a key. Users have frequently requested for the 
ability to perform partial updates i.e update select fields or a part of the 
record. This PR intends to add `update` to Table API.
   
   **Changes:**
   - Added `updateAsync` and `updateAllAsync` methods to `TableWriteFunction` 
and to `AsyncReadWriteTable`
   - All implementations of `AsyncReadWriteTable` have been changed to 
accommodate the API change
   - Added `sendUpdateTo` method to `MessageStream`. Added corresponding 
operator spec and operator implementation as well
   
   **Tests:**
   - Added tests for changes to all table implementations
   
   **API Changes**
   - TableWriteFunction was earlier using K,V generic types to represent key 
and record type. With partial updates, U type has been added to represent 
partial updates which is a backward compatible change
   - Similarly, U update generic type was added to AsyncReadWriteTable class 
generic signature. It affects all implementing classes as well.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]


Reply via email to