Searched refs:mr_spec (Results 1 – 4 of 4) sorted by relevance
| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/ |
| D | map_job_config.py | 150 mr_spec, argument
167 mapper_spec = mr_spec.mapper
169 api_version = mr_spec.params.get("api_version", 0)
193 job_name=mr_spec.name,
194 job_id=mr_spec.mapreduce_id,
203 user_params=mr_spec.params.get("user_params"),
204 shard_max_attempts=mr_spec.params.get("shard_max_attempts"),
205 done_callback_url=mr_spec.params.get("done_callback"),
206 _force_writes=mr_spec.params.get("force_writes"),
207 _base_path=mr_spec.params["base_path"],
[all …]
|
| D | output_writer.py | 145 def _recover(self, mr_spec, shard_number, shard_attempt): argument
|
| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/ |
| D | output_writers.py | 175 def create(cls, mr_spec, shard_number, shard_attempt, _writer_state=None): argument
256 def _recover(self, mr_spec, shard_number, shard_attempt): argument
729 def create(cls, mr_spec, shard_number, shard_attempt, _writer_state=None): argument
731 writer_spec = cls.get_params(mr_spec.mapper, allow_old=False)
737 key = cls._generate_filename(writer_spec, mr_spec.name,
738 mr_spec.mapreduce_id,
787 mr_spec = ctx.mapreduce_spec
788 writer_spec = self.get_params(mr_spec.mapper, allow_old=False)
790 mr_spec.name,
791 mr_spec.mapreduce_id,
[all …]
|
| D | shuffler.py | 473 def create(cls, mr_spec, shard_number, shard_attempt, _writer_state=None): argument
475 mapper_spec = mr_spec.mapper
481 filename = (mr_spec.name + "/" + mr_spec.mapreduce_id +
|