Are you using Python or Java? In Java, there is a good example in the chapter 7 <https://www.packtpub.com/en-us/product/building-big-data-pipelines-with-apache-beam-9781800564930> of this book (repo with code <https://github.com/PacktPublishing/Building-Big-Data-Pipelines-with-Apache-Beam/tree/main/chapter7> for that chapter).
In Python, see this Beam Summit workshop <https://2022.beamsummit.org/sessions/splittable-dofns-in-python/>, and the corresponding repo <https://github.com/iht/splittable-dofns-python>. I hope this helps. Israel On Wed, 9 Jul 2025 at 00:59, Zack Culberson <[email protected]> wrote: > Hi all, > > I have been looking for a working example of a splitable DoFn and what is > needed to implement one. I have added some of the restrictions and other > functions that are needed but wanted to see if there was a good example to > look at to build a splitable DoFn. > > Thank you , > Zack > ------------------------------ > Warning: All e-mail sent to this address will be received by the corporate > e-mail system, and is subject to archival and review by someone other than > the recipient. This e-mail may contain proprietary information and is > intended only for the use of the intended recipient(s). If the reader of > this message is not the intended recipient(s), you are notified that you > have received this message in error and that any review, dissemination, > distribution or copying of this message is strictly prohibited. If you have > received this message in error, please notify the sender immediately. > ------------------------------ >
