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

juripetersen merged 7 commits into

apache:mainapache/wayang:mainfrom

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