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

  /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/
model_datastore_input_reader.py 10 from mapreduce import namespace_range
55 ns_range = namespace_range.NamespaceRange(
61 ns_keys = namespace_range.get_namespace_keys(
68 ns_ranges = [namespace_range.NamespaceRange(_app=query_spec.app)
72 ns_ranges = namespace_range.NamespaceRange.split(n=shard_count,
abstract_datastore_input_reader.py 11 from mapreduce import namespace_range
101 ns_keys = namespace_range.get_namespace_keys(
115 ns_ranges = namespace_range.NamespaceRange.split(n=shard_count,
  /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/
key_ranges.py 7 from mapreduce import namespace_range
37 ns_range: a namespace_range.NameSpace Range object.
163 namespace_range.NamespaceRange.from_json_object(json["ns_range"]))
namespace_range.py 404 namespace_range = ranges.pop(0)
405 if namespace_range.is_single_namespace:
406 singles.append(namespace_range)
408 left, right = namespace_range.split_range()
input_readers.py 72 from mapreduce import namespace_range
344 ns_keys = namespace_range.get_namespace_keys(
358 ns_ranges = namespace_range.NamespaceRange.split(n=shard_count,
740 ns_range = namespace_range.NamespaceRange(
746 ns_keys = namespace_range.get_namespace_keys(
753 ns_ranges = [namespace_range.NamespaceRange(_app=query_spec.app)
757 ns_ranges = namespace_range.NamespaceRange.split(n=oversplit_shard_count,
825 NAMESPACE_RANGE_PARAM = "namespace_range"
848 ns_range: a namespace_range.NamespaceRange to process. Only one of
    [all...]
datastore_range_iterators.py 15 from mapreduce import namespace_range
212 namespace_range.NamespaceRange.from_json_object(json["ns_range"]),

Completed in 46 milliseconds