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.
>>
>
>
