| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/ |
| D | abstract_datastore_input_reader.py | 92 shard_count = job_config.shard_count
99 query_spec.app, [query_spec.ns], shard_count, query_spec)
112 query_spec.app, namespaces, shard_count, query_spec)
115 ns_ranges = namespace_range.NamespaceRange.split(n=shard_count,
128 def _to_key_ranges_by_shard(cls, app, namespaces, shard_count, query_spec): argument
148 shard_count,
160 ranges_by_shard = [[] for _ in range(shard_count)]
175 shard_count, argument
194 if shard_count == 1:
204 random_keys = ds_query.Get(shard_count * oversampling_factor)
[all …]
|
| D | sample_input_reader.py | 75 shard_count = job_config.shard_count
76 count_per_shard = count // shard_count
79 cls(count_per_shard, string_length) for _ in range(shard_count)]
81 left = count - count_per_shard*shard_count
|
| D | map_job_config.py | 62 shard_count = _Option(int, variable in JobConfig
118 shard_count=self.shard_count,
201 shard_count=mapper_spec.shard_count,
|
| D | model_datastore_input_reader.py | 43 shard_count = job_config.shard_count
51 p_ranges = p_range.split(shard_count)
72 ns_ranges = namespace_range.NamespaceRange.split(n=shard_count,
|
| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/ |
| D | input_readers.py | 336 shard_count = mapper_spec.shard_count
342 query_spec.app, [query_spec.ns], shard_count, query_spec)
355 query_spec.app, namespaces, shard_count, query_spec)
358 ns_ranges = namespace_range.NamespaceRange.split(n=shard_count,
371 def _to_key_ranges_by_shard(cls, app, namespaces, shard_count, query_spec): argument
391 shard_count,
404 ranges_by_shard = [[] for _ in range(shard_count)]
419 shard_count, argument
439 if shard_count == 1:
455 random_keys = ds_query_with_filters.Get(shard_count *
[all …]
|
| D | control.py | 41 shard_count=None, argument
88 if shard_count is None:
89 shard_count = parameters.config.SHARD_COUNT
107 shard_count,
|
| D | model.py | 357 shard_count, argument
378 self.shard_count = int(shard_count)
418 "mapper_shard_count": self.shard_count
427 self.shard_count)
664 shard_count = len(shards_processed)
666 if shard_count > 95:
668 pixels_per_shard = 700.0 / shard_count
674 if shards_processed and shard_count <= 95:
678 stride_length = max(1, shard_count / 16)
680 for x in xrange(shard_count):
[all …]
|
| /external/autotest/server/site_tests/video_VDAStress/ |
| D | generate_controlfiles.py | 65 shard_count = 10 variable
67 for shard_number in xrange(0, shard_count):
73 shard_number, shard_count))
|
| /external/autotest/server/site_tests/video_VDAStressSetup/ |
| D | video_VDAStressSetup.py | 23 shard_count): argument
39 shard_size = int(math.ceil(video_count / float(shard_count)))
|
| /external/v8/tools/ |
| D | run-tests.py | 536 shard_count = int(os.environ.get('GTEST_TOTAL_SHARDS', options.shard_count))
544 if options.shard_count > 1:
547 if options.shard_count != shard_count:
554 if shard_count < 2:
556 if shard_run < 1 or shard_run > shard_count:
563 if count % shard_count == shard_run - 1:
|
| D | run-deopt-fuzzer.py | 276 def ShardTests(tests, shard_count, shard_run): argument
277 if shard_count < 2:
279 if shard_run < 1 or shard_run > shard_count:
286 if count % shard_count == shard_run - 1:
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/boto/kinesis/ |
| D | layer1.py | 91 def create_stream(self, stream_name, shard_count): argument
160 'ShardCount': shard_count,
|
| /external/autotest/client/site_tests/graphics_dEQP/ |
| D | control.egl.info | 25 'shard_count=1'])
|
| D | control.gles31.info | 25 'shard_count=1'])
|
| D | control.egl.performance | 25 'shard_count=1'])
|
| D | control.egl.functional | 25 'shard_count=1'])
|
| D | control.egl.info.NotPass | 26 'shard_count=1'])
|
| D | control.gles31.info.NotPass | 26 'shard_count=1'])
|
| D | control.gles31.functional | 25 'shard_count=1'])
|
| D | control.egl.performance.NotPass | 26 'shard_count=1'])
|
| D | control.egl.functional.NotPass | 26 'shard_count=1'])
|
| D | control.gles31.stress | 25 'shard_count=1'])
|
| D | control.gles31.functional.NotPass | 26 'shard_count=1'])
|
| D | control.egl.stress.NotPass | 26 'shard_count=1'])
|
| D | control.egl.stress | 25 'shard_count=1'])
|