Is there a grouping option what will let me send spout output to each worker/JVM in my topology? I see the "allGrouping" option, which would send the tuple to each task.
Is there anything to send to each worker instead? The background here is that I have a JVM-level cache (Ehcache) and I'd like to invalidate certain objects in the cache based on input tuples. If I go with "allGrouping" I think it would work - the first task in a JVM to receive the tuple would clear the cache, and all the other tasks on that worker would just waste a little time trying to do the same.
