----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/20022/ -----------------------------------------------------------
(Updated April 17, 2014, 8:35 p.m.) Review request for samza. Repository: samza Description (updated) ------- rename message chooser buffer to buffering message chooser remove depleted queue threshold and fetch threshold pct add metrics back in more javadocs 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/SystemConsumers.scala bbbacb59866c2374853052f7cc11826552f5fb01 samza-core/src/main/scala/org/apache/samza/system/chooser/BufferingMessageChooser.scala PRE-CREATION Diff: https://reviews.apache.org/r/20022/diff/ Testing ------- Thanks, Chris Riccomini
