Searched refs:_recover (Results 1 - 3 of 3) sorted by relevance
| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/ |
| H A D | output_writer.py | 145 def _recover(self, mr_spec, shard_number, shard_attempt): member in class:OutputWriter
150 with its storage medium due to a retry of a slice. _recover should
|
| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/ |
| H A D | output_writers.py | 256 def _recover(self, mr_spec, shard_number, shard_attempt): member in class:OutputWriter
261 with its storage medium due to a retry of a slice. _recover should
808 def _recover(self, mr_spec, shard_number, shard_attempt): member in class:_GoogleCloudStorageOutputWriter
1113 def _recover(self, mr_spec, shard_number, shard_attempt): member in class:_GoogleCloudStorageRecordOutputWriterBase
1114 return self._writer._recover(mr_spec, shard_number, shard_attempt)
|
| H A D | handlers.py | 823 tstate.output_writer = tstate.output_writer._recover(
|
Completed in 51 milliseconds