Class: Spark::Serializer::Oj

Inherits:
Marshal show all
Defined in:
lib/spark/serializer/oj.rb

Constant Summary

Constants included from Constant

Constant::ACCUMULATOR_ACK, Constant::CREATE_WORKER, Constant::DATA_EOF, Constant::KILL_WORKER, Constant::KILL_WORKER_AND_WAIT, Constant::SUCCESSFULLY_KILLED, Constant::UNSUCCESSFUL_KILLING, Constant::WORKER_DONE, Constant::WORKER_ERROR

Constants included from Helper::Serialize

Helper::Serialize::DIRECTIVE_CHARS, Helper::Serialize::DIRECTIVE_DOUBLES_BIG_ENDIAN, Helper::Serialize::DIRECTIVE_DOUBLE_BIG_ENDIAN, Helper::Serialize::DIRECTIVE_INTEGERS_BIG_ENDIAN, Helper::Serialize::DIRECTIVE_INTEGER_BIG_ENDIAN, Helper::Serialize::DIRECTIVE_LONGS_BIG_ENDIAN, Helper::Serialize::DIRECTIVE_LONG_BIG_ENDIAN, Helper::Serialize::DIRECTIVE_UNSIGNED_CHARS

Instance Attribute Summary

Attributes inherited from Base

#batch_size

Instance Method Summary collapse

Methods inherited from Base

#==, #batched?, #dump, #dump_to_java, #initialize, #load, #load_from_io, #load_from_iterator, #load_next_from_io, #read_int, #set, #try, #unbatch!

Methods included from Helper::Serialize

#pack_double, #pack_doubles, #pack_int, #pack_ints, #pack_long, #pack_longs, #pack_unsigned_chars, #unpack_chars, #unpack_int, #unpack_long

Constructor Details

This class inherits a constructor from Spark::Serializer::Base

Instance Method Details

#deserialize(data) ⇒ Object 



13
14
15
 
# File 'lib/spark/serializer/oj.rb', line 13

def deserialize(data)
  ::Oj::load(data)
end

#name ⇒ Object 



5
6
7
 
# File 'lib/spark/serializer/oj.rb', line 5

def name
  'oj'
end

#serialize(data) ⇒ Object 



9
10
11
 
# File 'lib/spark/serializer/oj.rb', line 9

def serialize(data)
  ::Oj::dump(data)
end