class Spark::Serializer::Compressed
Public Class Methods
new(serializer)
click to toggle source
# File lib/spark/serializer/compressed.rb, line 5 def initialize(serializer) @serializer = serializer end
Public Instance Methods
dump(data)
click to toggle source
# File lib/spark/serializer/compressed.rb, line 9 def dump(data) Zlib::Deflate.deflate(@serializer.dump(data)) end
load(data)
click to toggle source
# File lib/spark/serializer/compressed.rb, line 13 def load(data) @serializer.load(Zlib::Inflate.inflate(data)) end