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

  /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/
input_readers.py 69 from mapreduce import key_ranges
362 k_ranges = [key_ranges.KeyRangesFactory.create_from_ns_range(ns_range)
372 """Get a list of key_ranges.KeyRanges objects, one for each shard.
384 a list of key_ranges.KeyRanges objects.
413 key_ranges_by_shard.append(key_ranges.KeyRangesFactory.create_from_list(
835 key_ranges=None,
846 key_ranges: a sequence of key_range.KeyRange instances to process. Only
847 one of key_ranges or ns_range can be non-None.
849 key_ranges or ns_range can be non-None.
856 assert key_ranges is not None or ns_range is not None,
    [all...]
datastore_range_iterators.py 13 from mapreduce import key_ranges
75 k_ranges: a key_ranges._KeyRanges object.
288 """Create an iterator over a key_ranges.KeyRanges object."""
297 k_ranges: a key_ranges._KeyRanges object.
332 return {"key_ranges": self._key_ranges.to_json(),
342 obj = cls(key_ranges.KeyRangesFactory.from_json(json["key_ranges"]),
  /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/
abstract_datastore_input_reader.py 9 from mapreduce import key_ranges
119 k_ranges = [key_ranges.KeyRangesFactory.create_from_ns_range(ns_range)
129 """Get a list of key_ranges.KeyRanges objects, one for each shard.
141 a list of key_ranges.KeyRanges objects.
169 key_ranges_by_shard.append(key_ranges.KeyRangesFactory.create_from_list(

Completed in 57 milliseconds