GitHub user pdu-mn1 opened a pull request:
https://github.com/apache/samza/pull/446
sql: initial insert support for table destination
Table is another main type of IO abstraction in Samza which supports
both read and write (optional). For the table that do support writes, we
GitHub user Sanil15 opened a pull request:
https://github.com/apache/samza/pull/445
SAMZA-1609 Refactoring SamzaContainer to take SystemFactories as an
argument
- This is a pre-req to SEP-8
(https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=71013043)
- A subtask
GitHub user xinyuiscool opened a pull request:
https://github.com/apache/samza/pull/444
SAMZA-1615: Fix a couple of issues in ControlMessageSender
Two issues I found during testing: 1)
medaDataCache.getSystemStreamMetadata(): if we pass in partitionOnly to be
true, it will actually