Hi all,
Im quite new to using beam yaml. I am working with a CSV file and want to
implement some windowing logic to it.
Was wondering what is the right way to add timestamps to each element,
assuming I have a column including a timestamp.

I am aware of Beam Programming Guide (apache.org)
<https://beam.apache.org/documentation/programming-guide/#adding-timestamps-to-a-pcollections-elements>
part
but not sure how this can be implemented and used from yaml prespective.

Thanks
Yarden

Reply via email to