[jira] [Commented] (FLINK-2571) Add task hooks support in Storm-compatibility

["Matthias J. Sax (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/FLINK-2571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14982244#comment-14982244 ] 

Matthias J. Sax commented on FLINK-2571:
----------------------------------------

Are you working on this? Or is anything blocking your progress?

> Add task hooks support in Storm-compatibility 
> ----------------------------------------------
>
>                 Key: FLINK-2571
>                 URL: https://issues.apache.org/jira/browse/FLINK-2571
>             Project: Flink
>          Issue Type: New Feature
>          Components: Storm Compatibility
>            Reporter: fangfengbin
>            Assignee: fangfengbin
>            Priority: Minor
>
> Storm provides hooks with which users can insert custom code to run on any number of events(emit, cleanup, spoutAck...) within Storm. Users create a hook by extending the BaseTaskHook class and overriding the appropriate method for the event users want to catch. 
> There are two ways to register your hook:
> 1.In the open method of your spout or prepare method of your bolt using the TopologyContext#addTaskHook method.
> 2.Through the Storm configuration using the "topology.auto.task.hooks" config.You can use user-defined hooks class names as value of "topology.auto.task.hooks" .These hooks are automatically registered in every spout or bolt.
> When the events happen, it will get hooks-list from TopologyContext and call hooks function. 



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)