[
https://issues.apache.org/jira/browse/FLINK-2571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-2571.
-----------------------------------
Resolution: Won't Fix
The storm-compatibility layer will be removed in FLINK-10509.
> 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
(v7.6.3#76005)
