----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/19384/ -----------------------------------------------------------
(Updated March 21, 2014, 4:38 p.m.) Review request for samza. Changes ------- * Rename ReadableCoordinator to TaskCoordinators * Improve shutdown method signature Repository: samza Description (updated) ------- SAMZA-179 Rename ReadableCoordinator to TaskCoordinators; improve shutdown method signature SAMZA-179 Allow a task to detect when it has caught up, and shut down gracefully. Diffs (updated) ----- samza-api/src/main/java/org/apache/samza/task/TaskContext.java 611507ed340d9a3fb7b8cd5e0e0ce37b5561da32 samza-api/src/main/java/org/apache/samza/task/TaskCoordinator.java 192b226c9e6105cf666d484ac33bb0f854de7688 samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala c101b59f3e476dcc2e3b7870d53d0d36002f2434 samza-core/src/main/scala/org/apache/samza/container/TaskInstance.scala c4b135c0f46edaa7fc0e4c0bf909e1ffa9515242 samza-core/src/main/scala/org/apache/samza/task/ReadableCoordinator.scala aaf631ec7acd710ab8a5b288f696233223569b60 samza-core/src/main/scala/org/apache/samza/task/TaskCoordinators.scala PRE-CREATION samza-core/src/test/scala/org/apache/samza/container/TestTaskInstance.scala 27b4ca5d7995536aa66f63b7329caddf41865bb4 samza-core/src/test/scala/org/apache/samza/task/TestReadableCoordinator.scala c45ed9bb1b3916cd4c4043e36272b4e3508bfb87 samza-core/src/test/scala/org/apache/samza/task/TestTaskCoordinators.scala PRE-CREATION samza-test/src/test/scala/org/apache/samza/test/performance/TestSamzaContainerPerformance.scala 3dc263011b955cfccac83e71384b865f8fc2b722 Diff: https://reviews.apache.org/r/19384/diff/ Testing ------- Thanks, Martin Kleppmann
