[streaming] Fixed SlidingWindowStateIterator
[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
[FLINK-1058] [streaming] Streaming initial documentation
[streaming] DataStream type refactor for easier future extensions
[streaming] Invokables and tests added for fast batch/window reduce operations and aggregations
[streaming] window and batch operator added to DataStream + Documentation updated accordingly
[streaming] Updated logging to utilize SLF4J
[streaming] Added CoBatchGroupReduceInvokable, CoWindowGroupReduceInvokable and grouped variants
[streaming] Added counter aggregation
[streaming] Added checked exception to execution
[streaming] GroupedBatchReduce modified to batch by key, updated WindowReduce + Batch/Window reduce refactor
[streaming] Minor bug fixes in Connectors, StreamCollector & docs

This closes #115
[FLINK-989] Improve error message when not finding enough task slots.
[FLINK-1030] Refactor and clean up instance managers.
[FLINK-1094] Reworked, improved, and testes split assigners
Redesign Scheduler from pre-assignment to more flexible schedule-on-demand model