[streaming] Reduce operator added to ConnectedDataStream + test
[streaming] Updated directed emit to not use output names when all outputs are selected
[FLINK-1080] [streaming] Streaming aggregation added

Conflicts:
	flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
[streaming] Added TypeInfo to DataStream
[FLINK-1080] [streaming] Streaming aggregation update and refactor