Searched refs:shard_number (Results 1 - 11 of 11) sorted by relevance

/external/autotest/server/site_tests/video_VDAStress/
H A Dgenerate_controlfiles.py50 shard_number={3},
67 for shard_number in xrange(0, shard_count):
68 filename = 'control.%s.%s.%d' % (test.decoder, test.access, shard_number)
73 shard_number, shard_count))
/external/autotest/server/site_tests/video_VDAStressSetup/
H A Dvideo_VDAStressSetup.py22 def run_once(self, gs_bucket, server_videos_dir, videos, shard_number,
37 # download shard_number.
40 begin = shard_size * shard_number
41 end = min(video_count, shard_size * (shard_number + 1))
/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/
H A Doutput_writer.py145 def _recover(self, mr_spec, shard_number, shard_attempt):
161 shard_number: int shard number.
/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/
H A Dmap_job_context.py34 id: str. of format job_id-shard_number.
45 self.number = shard_state.shard_number
H A Doutput_writers.py175 def create(cls, mr_spec, shard_number, shard_attempt, _writer_state=None):
180 shard_number: int shard number.
256 def _recover(self, mr_spec, shard_number, shard_attempt):
272 shard_number: int shard number.
729 def create(cls, mr_spec, shard_number, shard_attempt, _writer_state=None):
739 shard_number, shard_attempt,
792 shard_state.shard_number)
808 def _recover(self, mr_spec, shard_number, shard_attempt):
837 shard_number,
912 def create(cls, mr_spec, shard_number, shard_attemp
[all...]
H A Dshuffler.py289 shard_number = ctx._shard_state.shard_number
290 filenames = mapper_spec.params[self.FILES_PARAM][shard_number]
473 def create(cls, mr_spec, shard_number, shard_attempt, _writer_state=None):
482 "/shard-" + str(shard_number) + "-bucket-")
H A Dhandlers.py722 shard_state.shard_number, shard_state.mapreduce_id)
824 tstate.mapreduce_spec, shard_state.shard_number,
862 tstate.mapreduce_spec, shard_state.shard_number, shard_attempts + 1)
1538 for shard_number, input_reader in enumerate(readers):
1539 shard_state = model.ShardState.create_new(spec.mapreduce_id, shard_number)
1558 for shard_number, shard_state in enumerate(shard_states):
1559 writers[shard_number] = writer_class.create(
1561 shard_state.shard_number, shard_state.retries + 1,
1567 for shard_number, (input_reader, output_writer) in enumerate(
1570 spec.mapreduce_id, shard_number)
[all...]
H A Dmodel.py879 shard_number: ordered number for this shard.
1040 shard_number = property(get_shard_number) variable in class:ShardState
1054 def shard_id_from_number(cls, mapreduce_id, shard_number):
1059 shard_number: shard number to compute id for as int.
1064 return "%s-%d" % (mapreduce_id, shard_number)
1150 def create_new(cls, mapreduce_id, shard_number):
1155 shard_number: shard number for which to create shard state.
1160 shard_id = cls.shard_id_from_number(mapreduce_id, shard_number)
H A Dstatus.py385 "shard_number": shard.shard_number,
394 all_shards.sort(key=lambda x: x["shard_number"])
/external/autotest/client/site_tests/graphics_dEQP/
H A Dgraphics_dEQP.py368 shard_number='0',
378 self._shard_number = int(options['shard_number'])
/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/static/
H A Dstatus.js659 row.append($('<td>').text(shard.shard_number));

Completed in 222 milliseconds