[
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)
