Home
last modified time | relevance | path

Searched refs:mapreduce_id (Results 1 – 9 of 9) sorted by relevance

/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/
Dmapper_pipeline.py86 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))
Dhandlers.py722 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 …]
Dmodel.py460 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 …]
Dstatus.py333 "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)
Doutput_writers.py738 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)
Dcontext.py414 self.mapreduce_id = self.mapreduce_spec.mapreduce_id
417 self.mapreduce_id = None
Dshuffler.py151 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/
Dstatus.js157 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/
Dmap_job_config.py194 job_id=mr_spec.mapreduce_id,