Hi, I have a question about creating a customStreamGrouping. Is it possible to do a mapping from all targetTasks to the worker where it located?
For example, in the prepare() method I could make a mapping of TaskID and their ComponentID (eg. Map<TaskID, ComponentID>). But rather than only string of componentID, I need more higher level information like the workers or (if possible) even their supervisors. What I'm trying to do is to divide the supervisors/workers into 2 different cluster (Supervisors_A and Supervisors_B) and only send the stream inside the same cluster. So I need to know where the targetTasks is located. At first, I'm thinking to send the information from Nimbus that have the full information. But then I'm confused when I should send the information before the prepare() method in my CustomGrouping class is called. Is there anyone having this similar problem? Thank you Best Regards, Ken Danniswara
