Hi!
I think there are four ways to do this:
1) Create a new abstract class "SerializableBaseTaskHook" that extends
BaseTaskHook and implements java.io.Serializabe. Then write the object into
bytes and put it into the config.
2) Offer in the StormCompatibilityAPI a method "public void addHook(X
Hi
@mjsax @StephanEwen @rmetzger
Can you give me some suggestion about my idea of how to transfer user-defined
class code to task?
Thank you very much!
Regards
Fengbin Fang
#
Dear all,
I am work on task hooks of storm-compatibility. Storm support add hook through
the Storm
Dear all,
I am work on task hooks of storm-compatibility. Storm support add hook through
the Storm configuration using the "topology.auto.task.hooks" config. Users can
use user-defined hooks class names as value of "topology.auto.task.hooks" of
Configuration Map. These hooks are automatically r