module Spark::Helper::Serialize

Constants

DIRECTIVE_CHARS
DIRECTIVE_DOUBLES_BIG_ENDIAN
DIRECTIVE_DOUBLE_BIG_ENDIAN
DIRECTIVE_INTEGERS_BIG_ENDIAN
DIRECTIVE_INTEGER_BIG_ENDIAN
DIRECTIVE_LONGS_BIG_ENDIAN
DIRECTIVE_LONG_BIG_ENDIAN
DIRECTIVE_UNSIGNED_CHARS

Public Instance Methods

pack_double(data) click to toggle source
# File lib/spark/helper/serialize.rb, line 24
def pack_double(data)
  [data].pack(DIRECTIVE_DOUBLE_BIG_ENDIAN)
end
pack_doubles(data) click to toggle source
# File lib/spark/helper/serialize.rb, line 42
def pack_doubles(data)
  __check_array(data)
  data.pack(DIRECTIVE_DOUBLES_BIG_ENDIAN)
end
pack_int(data) click to toggle source

Packing

# File lib/spark/helper/serialize.rb, line 16
def pack_int(data)
  [data].pack(DIRECTIVE_INTEGER_BIG_ENDIAN)
end
pack_ints(data) click to toggle source
# File lib/spark/helper/serialize.rb, line 32
def pack_ints(data)
  __check_array(data)
  data.pack(DIRECTIVE_INTEGERS_BIG_ENDIAN)
end
pack_long(data) click to toggle source
# File lib/spark/helper/serialize.rb, line 20
def pack_long(data)
  [data].pack(DIRECTIVE_LONG_BIG_ENDIAN)
end
pack_longs(data) click to toggle source
# File lib/spark/helper/serialize.rb, line 37
def pack_longs(data)
  __check_array(data)
  data.pack(DIRECTIVE_LONGS_BIG_ENDIAN)
end
pack_unsigned_chars(data) click to toggle source
# File lib/spark/helper/serialize.rb, line 28
def pack_unsigned_chars(data)
  data.pack(DIRECTIVE_UNSIGNED_CHARS)
end
unpack_chars(data) click to toggle source
# File lib/spark/helper/serialize.rb, line 57
def unpack_chars(data)
  data.unpack(DIRECTIVE_CHARS)
end
unpack_int(data) click to toggle source

Unpacking

# File lib/spark/helper/serialize.rb, line 49
def unpack_int(data)
  data.unpack(DIRECTIVE_INTEGER_BIG_ENDIAN)[0]
end
unpack_long(data) click to toggle source
# File lib/spark/helper/serialize.rb, line 53
def unpack_long(data)
  data.unpack(DIRECTIVE_LONG_BIG_ENDIAN)[0]
end

Private Instance Methods

__check_array(data) click to toggle source
# File lib/spark/helper/serialize.rb, line 63
def __check_array(data)
  unless data.is_a?(Array)
    raise ArgumentError, 'Data must be an Array.'
  end
end