Hi Aniruddh, You can definitely write multiple GroupBy transforms in a Beam pipeline, regardless of whether the source is bounded or unbounded. I am not very clear about your exact use case, but you can use the Window transform to choose the appropriate windowing strategy you need. Here is one example: https://github.com/apache/beam/blob/master/examples/java/src/main/java/org/apache/beam/examples/complete/game/LeaderBoard.java
Best, Robin On Thu, Sep 13, 2018 at 2:36 PM [email protected] <[email protected]> wrote: > Hi > > from documentation groupby is applied on key and window basis. > > If my source is Pubsub (unbounded) - does Beam support applying multiple > groupby transformations and all of applied groupby transformation execute > in a single window. Or is only one groupby operation supported for > unbounded sources. > > > Thanks > Aniruddh >
