Hi, as you can see from the URL, its the documentation for Flink 0.8. The current documentation is here: https://ci.apache.org/projects/flink/flink-docs-release-0.10/apis/streaming_guide.html
In the 0.10. release announcement ( http://flink.apache.org/news/2015/11/16/release-0.10.0.html ) the change has been mentioned. On Wed, Jan 20, 2016 at 3:47 PM, Vinaya M S <vinay...@gmail.com> wrote: > Version FLink 0.10. > > Example is mentioned in > https://ci.apache.org/projects/flink/flink-docs-release-0.8/streaming_guide.html > Please let me know where I can find these kind of updates. > > Thank you. > > On Wed, Jan 20, 2016 at 9:41 AM, Robert Metzger <rmetz...@apache.org> > wrote: > >> Hi. >> >> which Flink version are you using? >> Starting from Flink 0.10., "groupBy" has been renamed to "keyBy". >> >> Where did you find the "groupBy" example? >> >> On Wed, Jan 20, 2016 at 3:37 PM, Vinaya M S <vinay...@gmail.com> wrote: >> >>> Hi, >>> >>> I'm new to Flink. Can anyone help me with the error below. >>> >>> Exception in thread "main" java.lang.Error: Unresolved compilation >>> problem: >>> >>> The method groupBy(int) is undefined for the type >>> SingleOutputStreamOperator<Tuple2<String,Integer>,capture#1-of ?> >>> >>> >>> The code snippet is: >>> >>> DataStream<Tuple2<String, Integer>> dataStream = env >>> >>> .socketTextStream("localhost", 9999) >>> >>> .flatMap(new Splitter()) >>> >>> .groupBy(0) >>> >>> .sum(1); >>> >>> >>> Thank you. >>> >> >> >
