Adapt documentation: https://beam.apache.org/documentation/transforms/python/elementwise/pardo/#example-1-pardo-with-a-simple-dofn <https://beam.apache.org/documentation/transforms/python/elementwise/pardo/#example-1-pardo-with-a-simple-dofn>
## Can be removed > [BEAM-7885] <https://issues.apache.org/jira/browse/BEAM-7885> DoFn.setup() > doesn’t run for streaming jobs running in the DirectRunner. Issue has been resolved. ## Can be changed > self.window = beam.window.GlobalWindow() New path is: > beam.transforms.window.GlobalWindow() Sincerely Kirill Ism