You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/02/07 02:48:00 UTC
[jira] [Commented] (SAMZA-1498) Support arbitrary system clock timer in operators

    [ 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 <xi...@...>
Date:   2018-02-01T21:57:48Z

    SAMZA-1498: Support arbitrary system clock timer in operators

commit a239b84dd75c018db2b14cbf138501e017957434
Author: xiliu <xi...@...>
Date:   2018-02-02T21:28:11Z

    Fix checkstyle issues

commit 3be14b394e029016014819e15d12d52f86be6fbc
Author: xiliu <xi...@...>
Date:   2018-02-02T23:28:32Z

    Change init function interface

commit 2f4bf429728e4dfdc1d8c51968ea774d117d5e87
Author: xiliu <xi...@...>
Date:   2018-02-02T23:30:26Z

    Some factoring on the init()

commit f9492cff1b636845e5ce15f22235e6568b952cd0
Author: xiliu <xi...@...>
Date:   2018-02-03T00:44:00Z

    Another adjustment of the API

commit e13d077c7ee0d5a0be3f79469563a2bdb343bfe5
Author: xiliu <xi...@...>
Date:   2018-02-07T01:50:55Z

    Java docs and unit tests

commit e6c1918cf076751fbdc53ad68a36656a212a4afb
Author: xiliu <xi...@...>
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)