Encode a message into 'RecordIO' format. :param message: a message to serialize and then wrap in a 'RecordIO' frame. :type message: object :returns: a serialized message wrapped in a 'RecordIO' frame :rtype: bytes
(self, message)
| 64 | self.serialize = serialize |
| 65 | |
| 66 | def encode(self, message): |
| 67 | """ |
| 68 | Encode a message into 'RecordIO' format. |
| 69 | |
| 70 | :param message: a message to serialize and then wrap in |
| 71 | a 'RecordIO' frame. |
| 72 | :type message: object |
| 73 | :returns: a serialized message wrapped in a 'RecordIO' frame |
| 74 | :rtype: bytes |
| 75 | """ |
| 76 | |
| 77 | s = self.serialize(message) |
| 78 | |
| 79 | if not isinstance(s, bytes): |
| 80 | raise MesosException("Calling 'serialize(message)' must" |
| 81 | " return a 'bytes' object") |
| 82 | |
| 83 | return bytes(str(len(s)) + "\n", "UTF-8") + s |
| 84 | |
| 85 | |
| 86 | class Decoder(): |