HomeSort by relevance Sort by last modified time
    Searched refs:k_ranges (Results 1 - 3 of 3) sorted by null

  /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/
abstract_datastore_input_reader.py 98 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/
datastore_range_iterators.py 69 k_ranges,
75 k_ranges: a key_ranges._KeyRanges object.
84 return _KeyRangesIterator(k_ranges, query_spec, key_range_iter_cls)
291 k_ranges,
297 k_ranges: a key_ranges._KeyRanges object.
303 self._key_ranges = k_ranges
input_readers.py 341 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...]

Completed in 49 milliseconds