flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Robert Metzger <rmetz...@apache.org>
Subject Re: groupBy(int) is undefined for the type SingleOutputStreamOperator while running streaming example provided on webpage
Date Wed, 20 Jan 2016 14:41:27 GMT
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