Searched refs:binary_record (Results 1 – 2 of 2) sorted by relevance
351 binary_record = reader.read()356 len(binary_record))(context.get())361 proto.ParseFromString(binary_record)618 def _hashing_map(binary_record): argument630 proto.ParseFromString(binary_record)
2619 binary_record = super(_ReducerReader, self).next()2621 proto.ParseFromString(binary_record)