I have been looking for sources in the web but I am still not finding the right information about Google DataFlow Python.

I have a CSV file with many columns and one of the columns that I need to process Date.

I created a Year column (new field) in the Transform part and I want to create a callable function to process the "Date" column to return the year part.

How can I write a Python Callable to do what I want?