Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Caching tables will not support updates.

Test Plan

  • Test plan would include unit tests to capture changes to the Table API and to the operator graph
  • Add tests for update in different table types: TestBatchTable, TestAsyncRetriableTable, TestRemoteTable, TestAsyncRateLimitedTable
  • Update End to end tests to test sendUpdateTo operator: TestRemoteTableEndToEnd, TestRemoteTableWithBatchEndToEnd
  • Samza remote store integrations will be tested with unit tests and test flows

Rollout

The plan is to release this feature with Samza 1.7  releases. The Table API changes are backward incompatible as AsyncReadWriteTable will now add a new generic type U to indicate an update in the class definition. Table integrations will have to be updated as well.

References

1. Samza Table API: https://samza.apache.org/learn/documentation/1.0.0/api/table-api.html

...