Added partitioner aware union, modified DStream.window.