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 <garvit...@gmail.com> wrote: > > Hi, > > How to do field grouping in Flink similar to what we have in storm. > > Please let me know. > > Thanks,
