Field Grouping in Flink

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

Field Grouping in Flink

Garvit Sharma
Hi,

How to do field grouping in Flink similar to what we have in storm.

Please let me know.

Thanks,

--

Garvit Sharma
github.com/garvitlnmiit/

No Body is a Scholar by birth, its only hard work and strong determination
that makes him master.
Reply | Threaded
Open this post in threaded view
|

Re: Field Grouping in Flink

xingcanc
Hi Garvit,

you can use the `keyBy()` method[1] to partition a stream like the field grouping in Storm.

Best,
Xingcan

[1] https://ci.apache.org/projects/flink/flink-docs-master/dev/stream/operators/#datastream-transformations

> On May 17, 2018, at 4:04 PM, Garvit Sharma <[hidden email]> wrote:
>
> Hi,
>
> How to do field grouping in Flink similar to what we have in storm.
>
> Please let me know.
>
> Thanks,