It has this error After some looking around, I think the problem was because I treated the Splittable DoFn as a regular DoFn. And they weren't any PCollection in the pipeline.
--------------------------------------------------------------------------- > AttributeError Traceback (most recent call last) > <ipython-input-4-980dbb4e11c7> in <module>() > 3 p > 4 | "ProduceNumbers" >> beam.ParDo(CountFn(10)) > ----> 5 | "Print" >> beam.Map(print) > 6 ) > 14 frames > /usr/local/lib/python3.7/dist-packages/apache_beam/transforms/ptransform.py > in get_windowing(self, inputs) > 560 """ > 561 if inputs: > --> 562 return inputs[0].windowing > 563 else: > 564 from apache_beam.transforms.core import Windowing AttributeError: 'PBegin' object has no attribute 'windowing' NB - I did some editing on the notebook so the original revision is here <https://colab.research.google.com/drive/1ljtoEtyG0gwbq6SPTY1EHHmpdh6EHuxu#scrollTo=vaXnHuVOtEdG> On Thu, Jul 14, 2022 at 10:15 PM Chamikara Jayalath via user < user@beam.apache.org> wrote: > Do you have the full stacktrace ? > Also, what does the Read() transform in the example entail ? > > Thanks, > Cham > > On Thu, Jul 14, 2022 at 7:39 AM Damian Akpan <damianakpan2...@gmail.com> > wrote: > >> Hi Everyone, >> >> I've been working on implementing a Google Sheets IO source for my >> pipeline. I've tried this example >> <https://beam.apache.org/documentation/programming-guide/#splittable-dofns> >> along >> with this blog <https://beam.apache.org/blog/splittable-do-fn/>. I have >> an example here on colab >> <https://colab.research.google.com/drive/1Fbq2jDqGcfJv7639tb_7-FkbRkQPCPxg?usp=sharing>. >> It returns "AttributeError: 'PBegin' object has no attribute 'windowing' " >> >> Please, what could I be doing wrong? >> >
