diff options
| author | Jey Kottalam <jey@cs.berkeley.edu> | 2013-03-10 13:54:46 -0700 |
|---|---|---|
| committer | Jey Kottalam <jey@cs.berkeley.edu> | 2013-06-21 12:14:16 -0400 |
| commit | 40afe0d2a5562738ef2ff37ed1d448ae2d0cc927 (patch) | |
| tree | 026ec3ad62e855f70eb38f633a41b2a3c365a65e /python/pyspark/serializers.py | |
| parent | 1057fccf2ac980501501cc27faaf42770a7de9a0 (diff) | |
| download | spark-40afe0d2a5562738ef2ff37ed1d448ae2d0cc927.tar.gz spark-40afe0d2a5562738ef2ff37ed1d448ae2d0cc927.tar.bz2 spark-40afe0d2a5562738ef2ff37ed1d448ae2d0cc927.zip | |
Add Python timing instrumentation
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 == "": |