| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/lib/input_reader/ |
| __init__.py | 3 from mapreduce.lib.input_reader._gcs import GCSInputReader
4 from mapreduce.lib.input_reader._gcs import GCSRecordInputReader
5 from mapreduce.lib.input_reader._gcs import PathFilter
|
| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/ |
| __init__.py | 10 from .input_reader import InputReader
|
| map_job_config.py | 8 from mapreduce.api.map_job import input_reader
45 input_reader_cls = _Option(input_reader.InputReader, required=True)
106 return {"input_reader": reader_params,
137 # also be necessary for launching input_reader/output_writer API. We don't
172 # Deserialize params from json if input_reader/output_writer are new API.
175 if issubclass(input_reader_cls, input_reader.InputReader):
|
| abstract_datastore_input_reader.py | 12 from mapreduce.api.map_job import input_reader
18 class AbstractDatastoreInputReader(input_reader.InputReader):
|
| /toolchain/binutils/binutils-2.25/gold/ |
| readsyms.h | 193 const Incremental_binary::Input_reader* input_reader,
195 : input_reader_(input_reader),
219 const Incremental_binary::Input_reader* input_reader_;
232 const Incremental_binary::Input_reader* input_reader,
235 input_reader_(input_reader), this_blocker_(this_blocker),
265 const Incremental_binary::Input_reader* input_reader_;
279 const Incremental_binary::Input_reader* input_reader,
[all...] |
| gold.cc | 328 const Incremental_binary::Input_reader* input_reader = local
330 Incremental_input_type input_type = input_reader->type();
339 Input_file_argument file(input_reader->filename(),
348 input_reader->filename(), input_type);
355 return new Check_script(layout, ibase, input_file_index, input_reader,
369 input_reader, this_blocker, next_blocker);
391 input_reader, this_blocker, next_blocker);
402 input_reader);
427 input_reader);
[all...] |
| incremental.h | [all...] |
| incremental.cc | 301 // Walk the list of input files (a) to setup an Input_reader for each
[all...] |
| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/ |
| control.py | 64 Should have format {"input_reader": {}, "output_writer":{}}. Old
|
| model.py | 744 input_reader,
757 input_reader: input reader instance for this shard.
769 self.input_reader = input_reader
774 self._input_reader_json = self.input_reader.to_json()
782 self.input_reader = self.initial_input_reader
799 self.input_reader = self.input_reader.from_json(self._input_reader_json)
808 "input_reader_state": self.input_reader.to_json_str(),
826 input_reader = mapper_spec.input_reader_class().from_json
[all...] |
| handlers.py | 408 self._maintain_LC(tstate.input_reader, slice_id)
414 self._maintain_LC(tstate.input_reader, slice_id, last_slice=last_slice,
503 tstate.input_reader, shard_state, tstate, ctx)
535 input_reader,
551 input_reader: input reader.
565 iterator = iter(input_reader)
593 entity, input_reader, ctx, tstate):
607 def _process_datum(self, data, input_reader, ctx, transient_shard_state):
614 input_reader: input reader.
629 if input_reader.expand_parameters
[all...] |
| status.py | 66 "input_reader": r".+",
92 - input_reader: google.appengine.ext.mapreduce.DatastoreInputReader
106 input_reader: Full <module_name>.<function_name/class_name> of the
136 "mapper_input_reader": config.mapper.input_reader,
|
| input_readers.py | 189 Input reader parameters are expected to be passed as "input_reader"
194 issue a warning if "input_reader" subdicationary is not present.
215 None, then parameters are expected to be in a separate "input_reader"
217 allow_old: Allow parameters to exist outside of the input_reader
226 if "input_reader" not in mapper_spec.params:
228 "input_reader subdictionary.")
234 if not isinstance(mapper_spec.params.get("input_reader"), dict):
237 params = mapper_spec.params.get("input_reader")
243 "Invalid input_reader parameters: %s" % ",".join(params_diff))
[all...] |
