Returns a serialized representation of 'value' suitable for use as a key in an MR streaming job.
(value)
| 31 | from tests.comparison.random_val_generator import RandomValGenerator |
| 32 | |
| 33 | def serialize(value): |
| 34 | '''Returns a serialized representation of 'value' suitable for use as a key in an MR |
| 35 | streaming job. |
| 36 | ''' |
| 37 | return base64.b64encode(pickle.dumps(value)) |
| 38 | |
| 39 | |
| 40 | def deserialize(value): |
no outgoing calls
no test coverage detected