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