Home
last modified time | relevance | path

Searched refs:mapper_params (Results 1 – 4 of 4) sorted by relevance

/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/
Dmapreduce_pipeline.py200 mapper_params=None, argument
206 if mapper_params.get("bucket_name") is None:
208 mapper_params["bucket_name"] = (
214 if mapper_params["bucket_name"] is None:
222 params=mapper_params,
225 job_name, mapper_params, map_pipeline)
231 mapper_params["bucket_name"],
Dhandlers.py1619 mapper_params = self._get_params(
1627 if "queue_name" in mapper_params:
1628 mr_params["queue_name"] = mapper_params["queue_name"]
1631 mapper_params["processing_rate"] = int(mapper_params.get(
1638 mapper_params,
1639 int(mapper_params.get("shard_count", parameters.config.SHARD_COUNT)),
1647 _app=mapper_params.get("_app"))
Dshuffler.py694 def run(self, job_name, mapper_params, filenames, shards=None): argument
695 bucket_name = mapper_params["bucket_name"]
/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/static/
Dstatus.js512 addParameters(config.mapper_params, 'mapper_params.');
578 if (detail.mapper_spec.mapper_params) {
579 var sortedKeys = getSortedKeys(detail.mapper_spec.mapper_params);
581 var value = detail.mapper_spec.mapper_params[key];