Searched refs:writer_state (Results 1 - 6 of 6) sorted by relevance

/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/
H A Doutput_writer.py114 shard_ctx._state.writer_state["outs"] = outs
H A Dmap_job_control.py112 yield iter(s.writer_state.get("outs", []))
/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/
H A Doutput_writers.py129 job. MapreduceState.writer_state can be modified during initialization
144 shared files into mapreduce_state.writer_state so that other operations
149 job. MapreduceState.writer_state can be modified during finalization.
204 into shard_state.writer_state so that other operations can find the
209 shard_state: shard state. ShardState.writer_state can be modified.
637 return shard_state.writer_state["filename"]
798 shard_state.writer_state = {self._SEG_PREFIX: prefix + "-",
802 shard_state.writer_state = {"filename": self._streaming_buffer.name}
1053 shard_state.writer_state = {"filename": self.status.mainfile.name}
H A Dshuffler.py497 shard_filenames = shard_state.writer_state["shard_filenames"]
508 shard_state.writer_state = {"shard_filenames": filenames}
H A Dmodel.py577 writer_state: Json property to be used by writer to store its state.
596 writer_state = json_util.JsonProperty(dict, indexed=False) variable in class:MapreduceState
885 writer_state: writer state for this shard. The shard's output writer
935 writer_state = json_util.JsonProperty(dict, indexed=False) variable in class:ShardState
H A Dhandlers.py1483 if not state.writer_state:
1562 mr_state.writer_state)

Completed in 117 milliseconds