Searched refs:mapreduce_id (Results 1 – 9 of 9) sorted by relevance
/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/ |
D | mapper_pipeline.py | 86 mapreduce_id = control.start_map( 100 self.fill(self.outputs.job_id, mapreduce_id) 102 (parameters.config.BASE_PATH, mapreduce_id))) 113 mapreduce_id = self.outputs.job_id.value 114 mapreduce_state = model.MapreduceState.get_by_job_id(mapreduce_id) 117 mapreduce_id, mapreduce_state.result_status))
|
D | handlers.py | 722 shard_state.shard_number, shard_state.mapreduce_id) 966 headers = util._get_task_headers(tstate.mapreduce_spec.mapreduce_id) 1105 model.MapreduceState.get_key_by_job_id(spec.mapreduce_id), 1106 model.MapreduceControl.get_key_by_job_id(spec.mapreduce_id), 1111 spec.mapreduce_id) 1116 spec.mapreduce_id) 1172 spec.mapreduce_id) 1174 model.MapreduceControl.abort(spec.mapreduce_id) 1181 model.MapreduceControl.abort(spec.mapreduce_id) 1199 fresh_state = model.MapreduceState.get_by_job_id(spec.mapreduce_id) [all …]
|
D | model.py | 460 mapreduce_id, argument 481 self.mapreduce_id = mapreduce_id 511 "mapreduce_id": self.mapreduce_id, 614 def get_key_by_job_id(cls, mapreduce_id): argument 623 return db.Key.from_path(cls.kind(), str(mapreduce_id)) 626 def get_by_job_id(cls, mapreduce_id): argument 635 return db.get(cls.get_key_by_job_id(mapreduce_id)) 703 def create_new(mapreduce_id=None, argument 711 if not mapreduce_id: 712 mapreduce_id = MapreduceState.new_mapreduce_id() [all …]
|
D | status.py | 333 "mapreduce_id": job.mapreduce_spec.mapreduce_id, 357 mapreduce_id = self.request.get("mapreduce_id") 358 if not mapreduce_id: 360 job = model.MapreduceState.get_by_key_name(mapreduce_id) 362 raise KeyError("Could not find job with ID %r" % mapreduce_id)
|
D | output_writers.py | 738 mr_spec.mapreduce_id, 791 mr_spec.mapreduce_id, 836 mr_spec.mapreduce_id, 856 self.mapreduce_id = None 918 mr_spec.mapreduce_id, 924 status.mapreduce_id = mr_spec.mapreduce_id 966 id=status.mapreduce_id, shard=status.shard, 1026 id=self.status.mapreduce_id, shard=self.status.shard)
|
D | context.py | 414 self.mapreduce_id = self.mapreduce_spec.mapreduce_id 417 self.mapreduce_id = None
|
D | shuffler.py | 151 filename = (ctx.mapreduce_spec.name + "/" + ctx.mapreduce_id + "/output-" + 163 parent=_OutputFile.get_root_key(ctx.mapreduce_id)) 481 filename = (mr_spec.name + "/" + mr_spec.mapreduce_id +
|
/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/static/ |
D | status.js | 157 function cleanUpJob(name, mapreduce_id) { argument 159 '" with ID "' + mapreduce_id + '"?')) { 167 data: {'mapreduce_id': mapreduce_id}, 177 $('#row-' + mapreduce_id).remove(); 185 function abortJob(name, mapreduce_id) { argument 186 if (!confirm('Abort job "' + name + '" with ID "' + mapreduce_id + '"?')) { 194 data: {'mapreduce_id': mapreduce_id}, 322 var row = $('<tr id="row-' + job.mapreduce_id + '">'); 329 .attr('href', 'detail?mapreduce_id=' + job.mapreduce_id) 332 row.append($('<td>').text(job.mapreduce_id)) [all …]
|
/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/ |
D | map_job_config.py | 194 job_id=mr_spec.mapreduce_id,
|