In python apache beam, is it possible to write elements in a specific order?
<p>I'm using beam to process time series data over overlapping windows. At the end of my pipeline I am writing each element to a file. Each element represents a csv row and one of the fields is a timestamp of the associated window. I would like to write the elements in order of that timestamp. Is there a way to do this using the python beam library? </p>

<p>While this isn't part of the base distribution, this is something you could implement by processing these elements and sorting them as part of a global window before writing out to a file, with the following caveats:</p>

<ul>
<li>The entire contents of the window would need to fit in memory, or you would need to chunk up the file into smaller global windows.</li>
<li>If you are doing the second option, you'd need to have a strategy for writing the smaller windows in order to the file. </li>
</ul>

python google-cloud-dataflow apache-beam