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

  /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/
model_datastore_input_reader.py 59 ns_ranges = [copy.copy(ns_range) for _ in p_ranges]
68 ns_ranges = [namespace_range.NamespaceRange(_app=query_spec.app)
72 ns_ranges = namespace_range.NamespaceRange.split(n=shard_count,
76 p_ranges = [copy.copy(p_range) for _ in ns_ranges]
78 assert len(p_ranges) == len(ns_ranges)
82 p, ns, query_spec) for p, ns in zip(p_ranges, ns_ranges)]
abstract_datastore_input_reader.py 115 ns_ranges = namespace_range.NamespaceRange.split(n=shard_count,
120 for ns_range in ns_ranges]
  /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/
namespace_range.py 414 ns_ranges = sorted(singles + ranges,
418 if not ns_ranges:
424 for i in range(len(ns_ranges)):
428 namespace_start = ns_ranges[i].namespace_start
430 if i == len(ns_ranges) - 1:
434 _namespace_to_ord(ns_ranges[i+1].namespace_start) - 1)
441 return ns_ranges
input_readers.py 358 ns_ranges = namespace_range.NamespaceRange.split(n=shard_count,
363 for ns_range in ns_ranges]
744 ns_ranges = [copy.copy(ns_range) for _ in p_ranges]
753 ns_ranges = [namespace_range.NamespaceRange(_app=query_spec.app)
757 ns_ranges = namespace_range.NamespaceRange.split(n=oversplit_shard_count,
761 p_ranges = [copy.copy(p_range) for _ in ns_ranges]
763 assert len(p_ranges) == len(ns_ranges)
767 p, ns, query_spec) for p, ns in zip(p_ranges, ns_ranges)]
    [all...]

Completed in 155 milliseconds