[FLINK-1103] [streaming] Updated WordCount example to become self-contained and removed old TestDataUtil
[FLINK-1121] [streaming] minBy and maxBy operators added to streaming api