Hi DannoHung,<p>Maybe this article could be of some value to you: <a href="http:&#x2F;&#x2F;flink.apache.org&#x2F;news&#x2F;2015&#x2F;02&#x2F;09&#x2F;streaming-example.html" rel="nofollow">http:&#x2F;&#x2F;flink.apache.org&#x2F;news&#x2F;2015&#x2F;02&#x2F;09&#x2F;streaming-example.ht...</a><p>Btw. handling DataStreams and DataSets in Flink is done via almost similar API calls. In DataStreams you only have to additionally insert the Time-Window parameters. Everything else (transformations like filter, map, flatMap etc.) remain the same.<p>Kind regards,
Harris