↓ 1 callersFunctiongroup_by_keyGroup identical keys together. Given a sorted iterator of (key, value) pairs, returns an iterator of (key1, values), (key2, values).
openfda/parallel/reducer.py:11
↓ 1 callersMethodinitialize(self, input_queue, tmp_prefix, output_class, output_prefix, shard_idx, num_shards)
openfda/parallel/reducer.py:36