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

["Chesnay Schepler (JIRA)" <ji...@apache.org>]

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