Home
last modified time | relevance | path

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

/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/
Ddatastore_range_iterators.py319 k_range = self._key_ranges.next()
320 self._current_iter = self._key_range_iter_cls(k_range,
370 def __init__(self, k_range, query_spec): argument
379 self._key_range = k_range
Dinput_readers.py406 for i, k_range in enumerate(ranges):
407 if k_range:
408 ranges_by_shard[i].append(k_range)
950 def _iter_key_range(self, k_range): argument
1079 for i, k_range in enumerate(key_ranges):
1080 shared_ranges[i % shard_count].append(k_range)
/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/
Dabstract_datastore_input_reader.py162 for i, k_range in enumerate(ranges):
163 if k_range:
164 ranges_by_shard[i].append(k_range)