[
https://issues.apache.org/jira/browse/SAMZA-1498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16354890#comment-16354890
]
ASF GitHub Bot commented on SAMZA-1498:
---
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
Date: 2018-02-01T21:57:48Z
SAMZA-1498: Support arbitrary system clock timer in operators
commit a239b84dd75c018db2b14cbf138501e017957434
Author: xiliu
Date: 2018-02-02T21:28:11Z
Fix checkstyle issues
commit 3be14b394e029016014819e15d12d52f86be6fbc
Author: xiliu
Date: 2018-02-02T23:28:32Z
Change init function interface
commit 2f4bf429728e4dfdc1d8c51968ea774d117d5e87
Author: xiliu
Date: 2018-02-02T23:30:26Z
Some factoring on the init()
commit f9492cff1b636845e5ce15f22235e6568b952cd0
Author: xiliu
Date: 2018-02-03T00:44:00Z
Another adjustment of the API
commit e13d077c7ee0d5a0be3f79469563a2bdb343bfe5
Author: xiliu
Date: 2018-02-07T01:50:55Z
Java docs and unit tests
commit e6c1918cf076751fbdc53ad68a36656a212a4afb
Author: 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
> Support arbitrary system clock timer in operators
> -
>
> Key: SAMZA-1498
> URL: https://issues.apache.org/jira/browse/SAMZA-1498
> Project: Samza
> Issue Type: Bug
>Reporter: Prateek Maheshwari
>Assignee: Xinyu Liu
>Priority: Minor
> Fix For: 0.15.0
>
>
> We need the capability of supporting any system-clock timers for user code.
> So user can register any timer as they like and they will get a callback in
> their functions. Internally we will be able to register the timer inside a
> scheduler and AsyncRunLoop will query the timers and fire the callback
> accordingly.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
