Once you've partitioned a trident stream using broadcast (so every tuple goes to every partition), how do you repartition the stream back down to 1 partition? Presumably doing it the naïve way would result in each tuple being duplicated by the broadcast partition number; how would you combine them? Using some sort of aggregator?
SimonC
