On Wed, Mar 31, 2021 at 10:20 AM Kenneth Knowles <[email protected]> wrote:
> > On Wed, Mar 31, 2021 at 10:19 AM Hemali Sutaria < > [email protected]> wrote: > >> I have a global window with per-key-and-window stateful processing >> dataflow job. Do I need groupbykey in my transform ? Thank you >> > No you do not need a GroupByKey. When you use a stateful DoFn the Beam runner will partition the data automatically by key and window. Kenn > >> >> https://cloud.google.com/blog/products/gcp/writing-dataflow-pipelines-with-scalability-in-mind >> >> https://beam.apache.org/documentation/programming-guide/#transforms >> >> >> https://beam.apache.org/blog/timely-processing/ >> >> >> Thanks, >> Hemali Sutaria >> >>
