Searched defs:shard_number (Results 1 – 5 of 5) sorted by relevance
/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 808 def _recover(self, mr_spec, shard_number, shard_attempt): argument 912 def create(cls, mr_spec, shard_number, shard_attempt, _writer_state=None): argument 1093 def create(cls, mr_spec, shard_number, shard_attempt, _writer_state=None): argument 1113 def _recover(self, mr_spec, shard_number, shard_attempt): argument
|
D | model.py | 1040 shard_number = property(get_shard_number) variable in ShardState 1054 def shard_id_from_number(cls, mapreduce_id, shard_number): argument 1150 def create_new(cls, mapreduce_id, shard_number): argument
|
D | shuffler.py | 473 def create(cls, mr_spec, shard_number, shard_attempt, _writer_state=None): argument
|
/external/autotest/server/site_tests/video_VDAStressSetup/ |
D | video_VDAStressSetup.py | 22 def run_once(self, gs_bucket, server_videos_dir, videos, shard_number, argument
|
/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/ |
D | output_writer.py | 145 def _recover(self, mr_spec, shard_number, shard_attempt): argument
|