Home
last modified time | relevance | path

Searched refs:input_reader (Results 1 – 7 of 7) sorted by relevance

/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/lib/input_reader/
D__init__.py3 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/
Dmap_job_config.py8 from mapreduce.api.map_job import input_reader
45 input_reader_cls = _Option(input_reader.InputReader, required=True)
175 if issubclass(input_reader_cls, input_reader.InputReader):
D__init__.py10 from .input_reader import InputReader
Dabstract_datastore_input_reader.py12 from mapreduce.api.map_job import input_reader
18 class AbstractDatastoreInputReader(input_reader.InputReader):
/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/
Dmodel.py744 input_reader, argument
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(
851 input_reader,
Dhandlers.py408 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, argument
565 iterator = iter(input_reader)
593 entity, input_reader, ctx, tstate):
607 def _process_datum(self, data, input_reader, ctx, transient_shard_state): argument
629 if input_reader.expand_parameters:
1538 for shard_number, input_reader in enumerate(readers):
1540 shard_state.shard_description = str(input_reader)
[all …]
Dstatus.py136 "mapper_input_reader": config.mapper.input_reader,