Searched refs:query_spec (Results 1 – 4 of 4) sorted by relevance
| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/ |
| D | 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 …]
|
| D | 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]
128 def _to_key_ranges_by_shard(cls, app, namespaces, shard_count, query_spec): argument
150 query_spec.entity_kind,
|
| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/ |
| D | datastore_range_iterators.py | 36 query_spec): argument
52 query_spec)
70 query_spec, argument
84 return _KeyRangesIterator(k_ranges, query_spec, key_range_iter_cls)
135 def __init__(self, p_range, ns_range, query_spec): argument
148 self._query_spec = query_spec
256 query_spec = json_item["query_spec"]
263 json["query_spec"] = query_spec
272 query_spec = json["query_spec"]
279 json_item["query_spec"] = query_spec
[all …]
|
| D | 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]
371 def _to_key_ranges_by_shard(cls, app, namespaces, shard_count, query_spec): argument
393 query_spec.entity_kind,
394 query_spec.filters,
[all …]
|