----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/20022/ -----------------------------------------------------------
(Updated April 17, 2014, 5:30 p.m.) Review request for samza. Repository: samza Description (updated) ------- move coordinator to buffer, and add javadocs move unprocessed messages into coordinator adding a message chooser coordinator to try and extract some of the confusing logic from system consumers into a separate class don't hard code the refresh threshold bump default max msgs per stream partition up to 10k add an unprocessed message counter black list empty system stream partitions Diffs (updated) ----- samza-core/src/main/scala/org/apache/samza/system/MessageChooserBuffer.scala PRE-CREATION samza-core/src/main/scala/org/apache/samza/system/SystemConsumers.scala bbbacb59866c2374853052f7cc11826552f5fb01 Diff: https://reviews.apache.org/r/20022/diff/ Testing ------- Thanks, Chris Riccomini
