GitHub user xinyuiscool opened a pull request:
https://github.com/apache/samza/pull/419
SAMZA-1498: Support arbitrary system clock timer in operators
This patch adds the capability to register arbitrary timers for both
high-level and low-level api.
For high-level, InitableFunction will pass the TimerRegistry to user
through the new OpContext, and user will implement the TimerFunction to get
timer notifications.
For low-level api, user can register timer in the TaskContext, and then
implements the TimerCallback for specific timer actions.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/xinyuiscool/samza SAMZA-1498
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/samza/pull/419.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #419
----
commit 35e93685e6c8955d19ad84d7255bee4a85b3d041
Author: xiliu <xiliu@...>
Date: 2018-02-01T21:57:48Z
SAMZA-1498: Support arbitrary system clock timer in operators
commit a239b84dd75c018db2b14cbf138501e017957434
Author: xiliu <xiliu@...>
Date: 2018-02-02T21:28:11Z
Fix checkstyle issues
commit 3be14b394e029016014819e15d12d52f86be6fbc
Author: xiliu <xiliu@...>
Date: 2018-02-02T23:28:32Z
Change init function interface
commit 2f4bf429728e4dfdc1d8c51968ea774d117d5e87
Author: xiliu <xiliu@...>
Date: 2018-02-02T23:30:26Z
Some factoring on the init()
commit f9492cff1b636845e5ce15f22235e6568b952cd0
Author: xiliu <xiliu@...>
Date: 2018-02-03T00:44:00Z
Another adjustment of the API
commit e13d077c7ee0d5a0be3f79469563a2bdb343bfe5
Author: xiliu <xiliu@...>
Date: 2018-02-07T01:50:55Z
Java docs and unit tests
commit e6c1918cf076751fbdc53ad68a36656a212a4afb
Author: xiliu <xiliu@...>
Date: 2018-02-07T02:37:02Z
Merge branch 'master' into SAMZA-1498
Conflicts:
samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala
----
---
