----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/18711/ -----------------------------------------------------------
(Updated March 7, 2014, 8:42 p.m.) Review request for samza. Repository: samza Description ------- merging in lastest from master adding tests for offset manager. cleaning up a random white space blip in TestUtil. move offset manager to checkpoint package. add documentation to offset manager. fix bootstrapping chooser to only use upcoming message offset. fix all tests. add stub tests for offset manager. add docs to offset manager merge master (SAMZA-142) add comment and logging to getDefaultOffset add offset manager. tests still failing, but everything is compiling. add getNextOffset to IncomingMessageEnvelope, and use it to checkpoint next offsets instead of current offsets. Diffs (updated) ----- build.gradle 31c54be samza-api/src/main/java/org/apache/samza/checkpoint/Checkpoint.java dcf81bf samza-api/src/main/java/org/apache/samza/system/IncomingMessageEnvelope.java 4b14312 samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java 32e142a samza-api/src/test/java/org/apache/samza/system/TestSystemStreamPartitionIterator.java 3ecabab samza-api/src/test/java/org/apache/samza/util/TestBlockingEnvelopeMap.java cb4d148 samza-core/src/main/scala/org/apache/samza/checkpoint/OffsetManager.scala PRE-CREATION samza-core/src/main/scala/org/apache/samza/config/StreamConfig.scala 517e9ae samza-core/src/main/scala/org/apache/samza/config/SystemConfig.scala ce63a8a samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala 9c23244 samza-core/src/main/scala/org/apache/samza/container/TaskInstance.scala 5127595 samza-core/src/main/scala/org/apache/samza/serializers/SerdeManager.scala 4f3ff6e samza-core/src/main/scala/org/apache/samza/system/chooser/BootstrappingChooser.scala f7d3c8b samza-core/src/test/scala/org/apache/samza/checkpoint/TestOffsetManager.scala PRE-CREATION samza-core/src/test/scala/org/apache/samza/container/TestSamzaContainer.scala a2d5820 samza-core/src/test/scala/org/apache/samza/container/TestTaskInstance.scala 5e9dd07 samza-core/src/test/scala/org/apache/samza/system/chooser/TestBatchingChooser.scala d7632b4 samza-core/src/test/scala/org/apache/samza/system/chooser/TestBootstrappingChooser.scala 993daa6 samza-core/src/test/scala/org/apache/samza/system/chooser/TestDefaultChooser.scala 884e458 samza-core/src/test/scala/org/apache/samza/system/chooser/TestRoundRobinChooser.scala 01802b9 samza-core/src/test/scala/org/apache/samza/system/chooser/TestTieredPriorityChooser.scala 4cde630 samza-core/src/test/scala/org/apache/samza/util/TestExponentialSleepStrategy.scala 3036da9 samza-core/src/test/scala/org/apache/samza/util/TestUtil.scala 60c9615 samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemAdmin.scala 5325549 samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemConsumer.scala afbd7cd samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemAdmin.scala eaa9e53 samza-test/src/main/java/org/apache/samza/system/mock/MockSystemAdmin.java 2abe1c8 samza-test/src/main/java/org/apache/samza/system/mock/MockSystemConsumer.java a282dbb samza-test/src/test/scala/org/apache/samza/test/integration/TestStatefulTask.scala 7e81387 samza-test/src/test/scala/org/apache/samza/test/performance/TestSamzaContainerPerformance.scala 3dc2630 Diff: https://reviews.apache.org/r/18711/diff/ Testing ------- Thanks, Chris Riccomini
