Searched refs:shard_number (Results 1 - 11 of 11) sorted by relevance
/external/autotest/server/site_tests/video_VDAStress/ |
H A D | generate_controlfiles.py | 50 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 D | video_VDAStressSetup.py | 22 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 D | output_writer.py | 145 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 D | map_job_context.py | 34 id: str. of format job_id-shard_number. 45 self.number = shard_state.shard_number
|
H A D | output_writers.py | 175 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 D | shuffler.py | 289 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 D | handlers.py | 722 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 D | model.py | 879 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 D | status.py | 385 "shard_number": shard.shard_number, 394 all_shards.sort(key=lambda x: x["shard_number"])
|
/external/autotest/client/site_tests/graphics_dEQP/ |
H A D | graphics_dEQP.py | 368 shard_number='0', 378 self._shard_number = int(options['shard_number'])
|
/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/static/ |
H A D | status.js | 659 row.append($('<td>').text(shard.shard_number));
|
Completed in 222 milliseconds