| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/ |
| mapper_pipeline.py | 86 mapreduce_id = control.start_map(
100 self.fill(self.outputs.job_id, mapreduce_id)
101 self.set_status(console_url="%s/detail?mapreduce_id=%s" % (
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))
|
| model.py | 460 mapreduce_id,
468 mapreduce_id: ID of the mapreduce.
475 mapreduce_id: unique id of this mapreduce as string.
481 self.mapreduce_id = mapreduce_id
511 "mapreduce_id": self.mapreduce_id,
528 json["mapreduce_id"],
614 def get_key_by_job_id(cls, mapreduce_id):
618 mapreduce_id: The job to retrieve
928 mapreduce_id = db.StringProperty(required=True) variable in class:ShardState
[all...] |
| handlers.py | 722 shard_state.shard_number, shard_state.mapreduce_id)
[all...] |
| main.py | 71 # Always suffix by mapreduce_id or shard_id for log analysis purposes.
72 # mapreduce_id or shard_id also presents in headers or payload.
|
| status.py | 333 "mapreduce_id": job.mapreduce_spec.mapreduce_id,
357 mapreduce_id = self.request.get("mapreduce_id")
358 if not mapreduce_id:
359 raise BadStatusParameterError("'mapreduce_id' was invalid")
360 job = model.MapreduceState.get_by_key_name(mapreduce_id)
362 raise KeyError("Could not find job with ID %r" % mapreduce_id)
|
| 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,
[all...] |
| context.py | 414 self.mapreduce_id = self.mapreduce_spec.mapreduce_id
417 self.mapreduce_id = None
|
| 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/ |
| status.js | 157 function cleanUpJob(name, mapreduce_id) {
159 '" with ID "' + mapreduce_id + '"?')) {
167 data: {'mapreduce_id': mapreduce_id},
177 $('#row-' + mapreduce_id).remove();
185 function abortJob(name, mapreduce_id) {
186 if (!confirm('Abort job "' + name + '" with ID "' + mapreduce_id + '"?')) {
194 data: {'mapreduce_id': mapreduce_id},
214 data: {'mapreduce_id': jobId}
[all...] |
| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/ |
| map_job_config.py | 194 job_id=mr_spec.mapreduce_id,
|
| map_job_control.py | 218 params = {"mapreduce_id": job_config.job_id}
|
