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

  /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/
model_datastore_input_reader.py 44 query_spec = cls._get_query_spec(params)
46 if not property_range.should_shard_by_property_range(query_spec.filters):
49 p_range = property_range.PropertyRange(query_spec.filters,
50 query_spec.model_class_path)
54 if query_spec.ns:
56 namespace_start=query_spec.ns,
57 namespace_end=query_spec.ns,
58 _app=query_spec.app)
62 query_spec.app, cls.MAX_NAMESPACES_FOR_KEY_SHARD+1)
68 ns_ranges = [namespace_range.NamespaceRange(_app=query_spec.app
    [all...]
abstract_datastore_input_reader.py 94 query_spec = cls._get_query_spec(params)
97 if query_spec.ns is not None:
99 query_spec.app, [query_spec.ns], shard_count, query_spec)
102 query_spec.app, cls.MAX_NAMESPACES_FOR_KEY_SHARD+1)
112 query_spec.app, namespaces, shard_count, query_spec)
118 _app=query_spec.app)
123 r, query_spec, cls._KEY_RANGE_ITER_CLS) for r in k_ranges
    [all...]
  /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/
datastore_range_iterators.py 36 query_spec):
44 query_spec: a model.QuerySpec object that defines how to retrieve
52 query_spec)
70 query_spec,
76 query_spec: a model.query_spec object that defines how to retrieve
84 return _KeyRangesIterator(k_ranges, query_spec, key_range_iter_cls)
135 def __init__(self, p_range, ns_range, query_spec):
143 query_spec: a model.QuerySpec object that defines how to retrieve
148 self._query_spec = query_spec
    [all...]
input_readers.py 337 query_spec = cls._get_query_spec(mapper_spec)
340 if query_spec.ns is not None:
342 query_spec.app, [query_spec.ns], shard_count, query_spec)
345 query_spec.app, cls.MAX_NAMESPACES_FOR_KEY_SHARD+1)
355 query_spec.app, namespaces, shard_count, query_spec)
361 _app=query_spec.app)
366 r, query_spec, cls._KEY_RANGE_ITER_CLS) for r in k_ranges
    [all...]

Completed in 67 milliseconds