Dynamic Topologies for Streams of Data