Github user raymondtay commented on a diff in the pull request:
https://github.com/apache/flink/pull/4666#discussion_r139849283
--- Diff: docs/dev/datastream_api.md ---
@@ -497,7 +497,9 @@ env.generateSequence(1,10).map(new
MyMapper()).setBufferTimeout(timeoutMillis);
LocalStreamEnvironment env =
StreamExecutionEnvironment.createLocalEnvironment
env.setBufferTimeout(timeoutMillis)
-env.genereateSequence(1,10).map(myMap).setBufferTimeout(timeoutMillis)
+def myMap : Long => Long = _ + 1 // `generateSequence` returns a
`DataStream[Long]` type
--- End diff --
I'm taking the perspective of the absolute beginner since this doc was
linked from the QuickStart section; when i started with the QuickStart section
most parts of the doc were good enough (imo) to guide me w/o referring to the
javadocs (which i think makes perfect sense) so i thought it might be a good
idea to continue this tradition and make things explicitly clear. What do you
think @zentol ?
---
