class Spark::Serializer::Base
@abstract Parent for all serializers
Public Instance Methods
==(other)
click to toggle source
# File lib/spark/serializer/base.rb, line 28 def ==(other) self.to_s == other.to_s end
batched?()
click to toggle source
# File lib/spark/serializer/base.rb, line 32 def batched? false end
check_each(data)
click to toggle source
# File lib/spark/serializer/base.rb, line 39 def check_each(data) unless data.respond_to?(:each) error('Data must be iterable.') end end
error(message)
click to toggle source
# File lib/spark/serializer/base.rb, line 45 def error(message) raise Spark::SerializeError, message end
inspect()
click to toggle source
# File lib/spark/serializer/base.rb, line 57 def inspect %{#<Spark::Serializer:0x#{object_id} "#{self}">} end
load_from_file(file, *args) { |item| ... }
click to toggle source
# File lib/spark/serializer/base.rb, line 17 def load_from_file(file, *args) return to_enum(__callee__, file, *args) unless block_given? load_from_io(file, *args).each do |item| yield item end file.close file.unlink end
load_from_io(io) { |load(read)| ... }
click to toggle source
# File lib/spark/serializer/base.rb, line 6 def load_from_io(io) return to_enum(__callee__, io) unless block_given? loop do size = io.read_int_or_eof break if size == Spark::Constant::DATA_EOF yield load(io.read(size)) end end
name()
click to toggle source
# File lib/spark/serializer/base.rb, line 49 def name self.class.name.split('::').last end
to_s()
click to toggle source
# File lib/spark/serializer/base.rb, line 53 def to_s name end
unbatch!()
click to toggle source
# File lib/spark/serializer/base.rb, line 36 def unbatch! end