run
Reads the corresponding partition.
This method gets called at most once.
This method is suspendable and may be cancelled due to a timeout. Implementations must be careful to always make at least some forward progress (according to the value returned by checkpoint) regardless of timeouts.