Thanks for writing this SEP!
Here's an alternate approach instead of taking the "String processorId" as
a parameter in the constructor. In my view, the "processorId" could be
generated by the StreamProcessor internally (instead of being generated
up-stream and passed in). The Job Coordinator API c
GitHub user xinyuiscool opened a pull request:
https://github.com/apache/samza/pull/94
SAMZA-1137: Instantiate ApplicationRunner in SamzaContainer
Create an ApplicationRunner in SamzaContainer to provide StreamSpecs for
fluent API.
You can merge this pull request into a Git reposit
GitHub user jmakes opened a pull request:
https://github.com/apache/samza/pull/93
samza-1156: Improve ApplicationRunner method naming and class structure
@navina @xinyuiscoool @nickpan47 take a look
You can merge this pull request into a Git repository by running:
$ git pull ht
