Home
last modified time | relevance | path

Searched refs:output_writer (Results 1 – 6 of 6) sorted by relevance

/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/
Dhandlers.py407 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 and
820 tstate.output_writer._supports_slice_recovery(mapper_spec)):
[all …]
Dmodel.py746 output_writer=None, argument
771 self.output_writer = output_writer
776 def reset_for_retry(self, output_writer): argument
785 self.output_writer = output_writer
812 if self.output_writer:
813 result["output_writer_state"] = self.output_writer.to_json_str()
833 output_writer = None
835 output_writer = mapper_spec.output_writer_class().from_json(
838 assert isinstance(output_writer, mapper_spec.output_writer_class()), (
841 output_writer.__class__))
[all …]
Dmap_job_context.py112 if not self._tstate.output_writer:
115 self._tstate.output_writer.write(value)
Dstatus.py151 if config.mapper.output_writer:
152 out["mapper_output_writer"] = config.mapper.output_writer
/external/chromium-trace/catapult/telemetry/telemetry/internal/platform/profiler/
Dmonsoon_profiler.py49 output_writer = csv.writer(output_file)
50 output_writer.writerows(plot_data)
/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/
D__init__.py14 from .output_writer import OutputWriter