----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33488/ -----------------------------------------------------------
(Updated May 7, 2015, 5:49 p.m.) Review request for samza. Bugs: SAMZA-657 https://issues.apache.org/jira/browse/SAMZA-657 Repository: samza Description (updated) ------- Rebase Diffs (updated) ----- README.md 0492790f4deeda9e230c34a36aba45d8242f1061 build.gradle ebad6eb27372d13bdb76506db2d4372b128f3c1e checkstyle/checkstyle.xml PRE-CREATION checkstyle/import-control.xml PRE-CREATION samza-api/src/main/java/org/apache/samza/config/Config.java 2b990506864c38ec2c46d55f27c2ba2f98f271ea samza-api/src/main/java/org/apache/samza/config/MapConfig.java 38d7424429d4bf81614311c39630b165236d8fbb samza-api/src/main/java/org/apache/samza/system/SystemStreamPartition.java 8dcea09ece60f91a890ff6b1abcb4e93c248dfe4 samza-api/src/main/java/org/apache/samza/util/BlockingEnvelopeMap.java e30321d521f0fd7d3d69e2858352916142fb27bf samza-api/src/main/java/org/apache/samza/util/SinglePartitionWithoutOffsetsSystemAdmin.java a6b14fb9ac200b8066af0d346ef373c29db90b9d samza-api/src/test/java/org/apache/samza/config/TestConfig.java d9f378d8de6da3bdf002e69dfb1e4605c3d90cec samza-api/src/test/java/org/apache/samza/system/TestSystemStreamPartitionIterator.java 5af2a11812983cfb8b6a8a0927ef6f3eba7d340f samza-api/src/test/java/org/apache/samza/util/TestBlockingEnvelopeMap.java 4eb87eb9033a45b5367480b9e38e18c629c79bc0 samza-core/src/main/java/org/apache/samza/checkpoint/CheckpointManager.java 3ac63cac1d5f4979b0fc1fa8598d0b25d5ce7b7f samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamMessage.java f8b705f4c05a2f167b740dfba17536724fffc8a7 samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamSystemConsumer.java 213460367945042a99221dce73610dbbff27fb78 samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamSystemProducer.java 0f3e10eb6e39c1ea4648bb0dd61d2d6d11d3c2e3 samza-core/src/main/java/org/apache/samza/serializers/model/SamzaObjectMapper.java 17410c50332b5e98bb3a8807faafaf583f60232c samza-core/src/main/java/org/apache/samza/storage/ChangelogPartitionManager.java fff7634ff3e3666dcce706db498b06a8fca79bc4 samza-core/src/main/scala/org/apache/samza/container/grouper/task/GroupByContainerCount.scala 8071fec3ac1bad76ddb3c6116e35c646be71d891 samza-core/src/test/java/org/apache/samza/coordinator/stream/MockCoordinatorStreamSystemFactory.java 59782fea2118c34d9ae8c9e259f3d02cc58eb224 samza-core/src/test/java/org/apache/samza/coordinator/stream/MockCoordinatorStreamWrappedConsumer.java 00a2d59ba836db2cae1a1f57804d027ffca9d84e samza-core/src/test/java/org/apache/samza/coordinator/stream/TestCoordinatorStreamMessage.java 15181bb0d3b028d4469fc57ae9acb6587fc25074 samza-core/src/test/java/org/apache/samza/coordinator/stream/TestCoordinatorStreamSystemConsumer.java 5e193f8aead1fb8ab71ff909d5c02271d4f62e3f samza-core/src/test/java/org/apache/samza/coordinator/stream/TestCoordinatorStreamSystemProducer.java 728fa533ef6a6c6232916cd50831a4fa2d628469 samza-core/src/test/java/org/apache/samza/serializers/model/TestSamzaObjectMapper.java 72b134c09b727d6550b6558f3362dbd64b9c94f7 samza-kv/src/main/java/org/apache/samza/storage/kv/KeyValueIterator.java 2fb26e28685928547342b325ff6f0a63b3d83887 samza-log4j/src/main/java/org/apache/samza/logging/log4j/StreamAppender.java d3616fe417a5a6e4f989c5ad212bcfa4a1aad290 samza-log4j/src/main/java/org/apache/samza/logging/log4j/serializers/LoggingEventStringSerde.java 8d8f5e8a8e5fd1e4d9e5482a5accd4a7ece463bc samza-log4j/src/test/java/org/apache/samza/config/TestLog4jSystemConfig.java 6314a3ed7ae6d49328ba3f32af5d9d1097899009 samza-log4j/src/test/java/org/apache/samza/logging/log4j/TestJmxAppender.java 0bdade0d7c097bcb33acdfc8077c1ce57ad7988c samza-test/src/main/java/org/apache/samza/system/mock/MockSystemAdmin.java 8c95211352655d5395c98d84f174d29734503be7 samza-test/src/main/java/org/apache/samza/test/integration/SimpleStatefulTask.java 67e56e0dd7b5cd2b636699f253e38c6265abf677 samza-test/src/main/java/org/apache/samza/test/integration/StatePerfTestTask.java d7fecd83abdb1a171140cb13e17661a06e1d77c3 samza-test/src/main/java/org/apache/samza/test/integration/join/Checker.java 0598e51c158d2865ddd40685b9a3243561b4f556 samza-test/src/main/java/org/apache/samza/test/integration/join/Emitter.java 82a633d4e796cde347c4398d85e1903be735d067 samza-test/src/main/java/org/apache/samza/test/integration/join/EpochPartitioner.java 438d77c0d393727d3e6fde19a2706efd6ea1ce09 samza-test/src/main/java/org/apache/samza/test/integration/join/Joiner.java d2c0c7eaf9c389e3f88b63a2eb7668b31d1b2daf samza-test/src/main/java/org/apache/samza/test/integration/join/Watcher.java 7c82e0a7ac6b175cca935fc058a96aaade92fbe0 Diff: https://reviews.apache.org/r/33488/diff/ Testing ------- ./gradlew checkstyleMain checkstyleTest Thanks, Guozhang Wang