Repository: samza
Updated Branches:
refs/heads/master eb5d452ae -> 05915bfc8
SAMZA-1093: instantiating StreamOperatorTask in SamzaContainer
SAMZA-1093: Instantiating StreamOperatorTask in SamzaContainer
- minor refactor to get the TaskFactory based on task class configuration
- add instantiat
Repository: samza
Updated Branches:
refs/heads/samza-fluent-api-v1 dde754246 -> a9b213c13
SAMZA-1093: instantiating StreamOperatorTask in SamzaContainer (WIP)
SAMZA-1093: Instantiating StreamOperatorTask in SamzaContainer
SAMZA-1093: fix import
SAMZA-1093: code ready, more unit tests pending