THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
- Introduce a new construct AdjunctDataStoreManager, its responsibility includes
- Maintains mapping between system streams and adjunct data stores
- Extract the key and value from an IncomingMessageEnvelop
- Updates Populates and updates relevant adjunct data stores
- TaskInstance will be modified to consult AdjunctDataStoreManager before delivering a message to a task, a message stored in an adjunct store is not delivered to task
- Introduce new configurations to "bind" a Samza store to one or more system stream
- Provide hooks to transform an incoming message to desired types (this is useful as not all everything needs to be cached)
...