GitHub user navina opened a pull request:
https://github.com/apache/samza/pull/44
Initial Standalone JobCoordinator and StreamProcessor API
This patch contains changes associated with the Standalone StreamProcessor,
where there is no coordination. This will work for load-balanced consumers like
new Kafka consumer and statically partitioned cases.
Additionally, we have introduced TaskFactory for StreamTask and
AsyncStreamTask.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/navina/samza Noop-JC
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/samza/pull/44.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #44
----
commit 76b5167e856984d627a73f020d4ca1c7e9ae8750
Author: Boris Shkolnik <[email protected]>
Date: 2017-01-23T21:16:49Z
added new line at then end
commit 47bf91f8676e26c0de531019e21b6660d744e13f
Author: Boris Shkolnik <[email protected]>
Date: 2017-01-06T20:22:16Z
SAMZA-1076; getKafkaChangelogEnabledStores() should use
StorageConfig.getChangeloâ¦
getKafkaChangelogEnabledStores() should use
StorageConfig.getChangelogStream to get changelog system.stream
Author: Boris Shkolnik <[email protected]>
Reviewers: xiliu <[email protected]>
Closes #39 from sborya/KafkConfigForChangelogStream
commit 0dda667b536b14ab12339fc7780db8a7a28bded4
Author: Xinyu Liu <[email protected]>
Date: 2017-01-11T18:42:26Z
SAMZA-1078: Add my gpg key to KEYS
Author: Xinyu Liu <[email protected]>
Closes #41 from xinyuiscool/KEYS
commit 0fc1b4d176c5c62012e32c745d46dc8315a96e3b
Author: navina <[email protected]>
Date: 2017-01-24T19:04:20Z
Adding StreamProcessor and JobCoordinator API along with TaskFactories
commit 70aa08d66d1a1555da69f2607c965d1bc5be0289
Author: navina <[email protected]>
Date: 2017-01-24T19:45:30Z
Removing SimpleGroupByContainer and SimpleGroupByContainerFactory
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
