flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Vinaya M S <vinay...@gmail.com>
Subject Re: groupBy(int) is undefined for the type SingleOutputStreamOperator while running streaming example provided on webpage
Date Wed, 20 Jan 2016 14:47:46 GMT
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 <rmetzger@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 <vinayams@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.
>>
>
>

Mime
View raw message