[streaming] Replaced connection types with StreamPartitioner in DataStream
[streaming] Merge branch 'streaming-new' of https://github.com/mbalassi/incubator-flink into streaming-new