Add vectorclock for each partition
Generate downstream operations in timestamp order