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

  /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/
__init__.py 14 from .output_writer import OutputWriter
  /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/
map_job_context.py 112 if not self._tstate.output_writer:
115 self._tstate.output_writer.write(value)
control.py 64 Should have format {"input_reader": {}, "output_writer":{}}. Old
model.py 746 output_writer=None,
760 output_writer: output writer instance for this shard, if exists.
771 self.output_writer = output_writer
776 def reset_for_retry(self, output_writer):
780 output_writer: new output writer that contains new output files.
785 self.output_writer = output_writer
812 if self.output_writer:
813 result["output_writer_state"] = self.output_writer.to_json_str(
    [all...]
handlers.py 407 self._maintain_LC(tstate.output_writer, slice_id)
416 self._maintain_LC(tstate.output_writer, slice_id, last_slice=last_slice,
487 if (tstate.output_writer and
488 isinstance(tstate.output_writer, output_writers.OutputWriter)):
493 tstate.output_writer.finalize(ctx, shard_state)
639 output_writer = transient_shard_state.output_writer
640 if not output_writer:
644 output_writer.write(output)
819 if not (tstate.output_writer an
    [all...]
status.py 67 "output_writer": validation.Optional(r".+"),
151 if config.mapper.output_writer:
152 out["mapper_output_writer"] = config.mapper.output_writer
output_writers.py 108 Output writer parameters are expected to be passed as "output_writer"
111 a warning if "output_writer" subdicationary is not present.
297 None, then parameters are expected to be in a separate "output_writer"
299 allow_old: Allow parameters to exist outside of the output_writer
308 if "output_writer" not in mapper_spec.params:
311 "output_writer subdictionary.")
317 if not isinstance(mapper_spec.params.get("output_writer"), dict):
320 params = mapper_spec.params.get("output_writer")
326 "Invalid output_writer parameters: %s" % ",".join(params_diff))
456 Required configuration in the mapper_spec.output_writer dictionary
    [all...]
  /external/chromium-trace/catapult/telemetry/telemetry/internal/platform/profiler/
monsoon_profiler.py 49 output_writer = csv.writer(output_file)
50 output_writer.writerows(plot_data)

Completed in 739 milliseconds