Source, map, collection, sink for bounded data streams in Flink#661

mspruc wants to merge 6 commits intoapache:mainapache/wayang:mainfrom

mspruc:flink-datastreammspruc/incubator-wayang:flink-datastreamCopy head branch name to clipboard