How to call custom functions in Filter in Apache Beam | google dataflow

[@soldebenedet92]

This videos are helping me a lot, thanks! please continue uploading examples like these :)

[@viswatejaforu]

Thanks for the feedback

[@kiranugalmugale4347]

Hi,
I am also reading Apache beam pipeline which is reading parquet file
And converting into json then I am dumping it into bigquery table
I am using datetime module in this as one one column is that type n i am creating custom encoder which results string as output
But problem is whenever I am running it on cloud dataflow it is giving me name error : datetime
What can be a issue
If I run same script from my local machine it works fine