Searched refs:slice_ctx (Results 1 – 7 of 7) sorted by relevance
| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/ |
| D | input_reader.py | 107 def begin_slice(self, slice_ctx): argument
113 self._slice_ctx = slice_ctx
115 def end_slice(self, slice_ctx): argument
|
| D | output_writer.py | 116 def begin_slice(self, slice_ctx): argument
122 self._slice_ctx = slice_ctx
124 def end_slice(self, slice_ctx): argument
|
| D | mapper.py | 34 def __call__(self, slice_ctx, val): argument
|
| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/ |
| D | shard_life_cycle.py | 51 def begin_slice(self, slice_ctx): argument
62 def end_slice(self, slice_ctx): argument
|
| D | output_writers.py | 759 def end_slice(self, slice_ctx): argument
971 def begin_slice(self, slice_ctx): argument
1004 def end_slice(self, slice_ctx): argument
1116 def begin_slice(self, slice_ctx): argument
1117 return self._writer.begin_slice(slice_ctx)
1119 def end_slice(self, slice_ctx): argument
1123 return self._writer.end_slice(slice_ctx)
|
| D | handlers.py | 379 shard_ctx=None, slice_ctx=None): argument
396 slice_context = slice_ctx or self.slice_context
|
| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/lib/input_reader/ |
| D | _gcs.py | 36 def accept(self, slice_ctx, path): argument
|