Searched refs:counters_map (Results 1 – 7 of 7) sorted by relevance
278 def add_map(self, counters_map): argument287 for counter_name in counters_map.counters:288 self.increment(counter_name, counters_map.counters[counter_name])290 def sub_map(self, counters_map): argument299 for counter_name in counters_map.counters:300 self.increment(counter_name, -counters_map.counters[counter_name])324 counters_map = cls()325 counters_map.counters = json["counters"]326 return counters_map593 counters_map = json_util.JsonProperty( variable in MapreduceState[all …]
57 self._state.counters_map.increment(counter_name, delta)69 return self._state.counters_map.get(counter_name, default)
128 self.fill(self.outputs.counters, mapreduce_state.counters_map.to_dict())
365 self.json_response.update(job.counters_map.to_json())392 out.update(shard.counters_map.to_json())
1140 state.counters_map.clear()1159 state.counters_map.add_map(s.counters_map)1160 processed_counts.append(s.counters_map.get(context.COUNTER_MAPPER_CALLS))
365 self._shard_state.counters_map.increment(counter_name, delta)
83 return self._state.counters_map.counters.iteritems()98 return self._state.counters_map.get(counter_name, default)