Home
last modified time | relevance | path

Searched refs:k_ranges (Results 1 – 3 of 3) sorted by relevance

/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/
Dabstract_datastore_input_reader.py98 k_ranges = cls._to_key_ranges_by_shard(
111 k_ranges = cls._to_key_ranges_by_shard(
119 k_ranges = [key_ranges.KeyRangesFactory.create_from_ns_range(ns_range)
123 r, query_spec, cls._KEY_RANGE_ITER_CLS) for r in k_ranges]
218 k_ranges = []
220 k_ranges.append(key_range.KeyRange(
230 k_ranges.append(key_range.KeyRange(
239 k_ranges.append(key_range.KeyRange(
248 if len(k_ranges) < shard_count:
250 k_ranges += [None] * (shard_count - len(k_ranges))
[all …]
/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/
Ddatastore_range_iterators.py69 k_ranges, argument
84 return _KeyRangesIterator(k_ranges, query_spec, key_range_iter_cls)
291 k_ranges, argument
303 self._key_ranges = k_ranges
Dinput_readers.py341 k_ranges = cls._to_key_ranges_by_shard(
354 k_ranges = cls._to_key_ranges_by_shard(
362 k_ranges = [key_ranges.KeyRangesFactory.create_from_ns_range(ns_range)
366 r, query_spec, cls._KEY_RANGE_ITER_CLS) for r in k_ranges]
478 k_ranges = []
480 k_ranges.append(key_range.KeyRange(
490 k_ranges.append(key_range.KeyRange(
499 k_ranges.append(key_range.KeyRange(
508 if len(k_ranges) < shard_count:
510 k_ranges += [None] * (shard_count - len(k_ranges))
[all …]