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


Reply via email to