diff options
| author | Tathagata Das <tathagata.das1565@gmail.com> | 2013-06-24 23:57:47 -0700 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2013-06-24 23:57:47 -0700 |
| commit | c89af0a7f9eebce22dfe2bb4d8b1676ec7f760f6 (patch) | |
| tree | 01f9f42f30a4aa2f73cb200c89a71254bf74d80e /python/pyspark/serializers.py | |
| parent | 48c7e373c62b2e8cf48157ceb0d92c38c3a40652 (diff) | |
| parent | 78ffe164b33c6b11a2e511442605acd2f795a1b5 (diff) | |
| download | spark-c89af0a7f9eebce22dfe2bb4d8b1676ec7f760f6.tar.gz spark-c89af0a7f9eebce22dfe2bb4d8b1676ec7f760f6.tar.bz2 spark-c89af0a7f9eebce22dfe2bb4d8b1676ec7f760f6.zip | |
Merge branch 'master' into streaming
Conflicts:
.gitignore
Diffstat (limited to 'python/pyspark/serializers.py')
| -rw-r--r-- | python/pyspark/serializers.py | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/python/pyspark/serializers.py b/python/pyspark/serializers.py index 115cf28cc2..5a95144983 100644 --- a/python/pyspark/serializers.py +++ b/python/pyspark/serializers.py @@ -46,6 +46,10 @@ def read_long(stream): return struct.unpack("!q", length)[0] +def write_long(value, stream): + stream.write(struct.pack("!q", value)) + + def read_int(stream): length = stream.read(4) if length == "": |