----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23588/ -----------------------------------------------------------
Review request for samza. Repository: samza Description ------- add a refresh threshold config cleaning up metrics in system consumers add docs all tests pass. misc test fixes to make new api work. slight refactoring in SystemConsumers. clean up erroneous import initial rebase without fixing file system conusmer. Diffs ----- samza-api/src/main/java/org/apache/samza/system/SystemConsumer.java 591f8fbfe5784766078789b00d5e7d777f051e2b samza-api/src/main/java/org/apache/samza/system/SystemStreamPartitionIterator.java 9acfb108906e24cc3b9d589bce252c764e3ae2ce samza-api/src/main/java/org/apache/samza/util/BlockingEnvelopeMap.java 9503739fc323f07aa156b4b18061b8a7ba838dd3 samza-api/src/test/java/org/apache/samza/system/TestSystemStreamPartitionIterator.java 3ecabab9230f64dab203e3e19659828cbaefeb0e samza-api/src/test/java/org/apache/samza/util/TestBlockingEnvelopeMap.java cb4d14854671ea602785581f7ed243dffde4ec26 samza-core/src/main/scala/org/apache/samza/config/TaskConfig.scala 8b881f2533975eea960e7a96b76763ef33af2a78 samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala b303615ca0978a92febe227fcf88b5acecce4223 samza-core/src/main/scala/org/apache/samza/system/SystemConsumers.scala 9eb70f298cbaef02e558c7a9dac0d0c5a914bd3f samza-core/src/main/scala/org/apache/samza/system/SystemConsumersMetrics.scala b065ae6c9f1295d9036d0285e3fa8c5dd1042ec9 samza-core/src/main/scala/org/apache/samza/system/chooser/BufferingMessageChooser.scala c7ef6ef051dd694d7f5f80e780b02ac4152ac81b samza-core/src/main/scala/org/apache/samza/system/chooser/RoundRobinChooser.scala 537412114105ee9124a32e7bda4ef95139612ec8 samza-core/src/test/scala/org/apache/samza/system/TestSystemConsumers.scala 97e65eb2c4269f32decd364af07de2ddce784f97 samza-core/src/test/scala/org/apache/samza/system/chooser/TestBufferingMessageChooser.scala c96c53bcf5dc89147166319a29930b6961e2dd41 samza-core/src/test/scala/org/apache/samza/system/filereader/TestFileReaderSystemConsumer.scala b2e04a74d690847e4494752b8d14deaaba5348b8 samza-test/src/main/scala/org/apache/samza/test/performance/TestPerformanceTask.scala 23d122e54fbefc6edfdfc1c0e3e6fa18f7141fcb samza-test/src/test/scala/org/apache/samza/test/performance/TestSamzaContainerPerformance.scala 4016768d9dd0098d74e35b88bcf95d238edec427 Diff: https://reviews.apache.org/r/23588/diff/ Testing ------- Thanks, Chris Riccomini
