Searched refs:writer_state (Results 1 – 6 of 6) sorted by relevance
114 shard_ctx._state.writer_state["outs"] = outs
112 yield iter(s.writer_state.get("outs", []))
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}
497 shard_filenames = shard_state.writer_state["shard_filenames"]508 shard_state.writer_state = {"shard_filenames": filenames}
596 writer_state = json_util.JsonProperty(dict, indexed=False) variable in MapreduceState935 writer_state = json_util.JsonProperty(dict, indexed=False) variable in ShardState
1483 if not state.writer_state:1562 mr_state.writer_state)