samza-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Boris Shkolnik <bor...@apache.org>
Subject Re: Review Request 53453: Add optional interface for SystemConsumer checkpontListener() for checkpoint notifications
Date Fri, 04 Nov 2016 23:23:41 GMT

-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/53453/
-----------------------------------------------------------

(Updated Nov. 4, 2016, 11:23 p.m.)


Review request for samza.


Bugs: SAMZA-1042
    https://issues.apache.org/jira/browse/SAMZA-1042


Repository: samza


Description
-------

Add optional interface for SystemConsumer checkpontListener() for checkpoint notifications.


Diffs (updated)
-----

  samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointListener.java PRE-CREATION

  samza-api/src/main/java/org/apache/samza/system/SystemConsumer.java 8dfcc7499659442aabd3085a8787475fe38f29db

  samza-core/src/main/scala/org/apache/samza/checkpoint/OffsetManager.scala c41eadb70f4675816245f7ac40f0db2fc16335f0

  samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala e0468ee89c89fd720834461771ebb36475475bcb

  samza-core/src/test/scala/org/apache/samza/checkpoint/TestOffsetManager.scala cb78223f1b59a78bbeb1e42b5974670a53def504


Diff: https://reviews.apache.org/r/53453/diff/


Testing (updated)
-------

gradlew test.
manual testing.


Thanks,

Boris Shkolnik


Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message