Module: Spark::CoreExtension::IO::InstanceMethods

Instance Method Summary collapse


29
30
31

# File 'lib/spark/ext/io.rb', line 29

def read_data
  Marshal.load(read_string)
end

Reading


11
12
13

# File 'lib/spark/ext/io.rb', line 11

def read_int
  unpack_int(read(4))
end

# File 'lib/spark/ext/io.rb', line 15

def read_int_or_eof
  bytes = read(4)
  return Spark::Constant::DATA_EOF if bytes.nil?
  unpack_int(bytes)
end


21
22
23

# File 'lib/spark/ext/io.rb', line 21

def read_long
  unpack_long(read(8))
end


25
26
27

# File 'lib/spark/ext/io.rb', line 25

def read_string
  read(read_int)
end


52
53
54

# File 'lib/spark/ext/io.rb', line 52

def write_data(data)
  write_string(Marshal.dump(data))
end

Writing


36
37
38

# File 'lib/spark/ext/io.rb', line 36

def write_int(data)
  write(pack_int(data))
end


40
41
42

# File 'lib/spark/ext/io.rb', line 40

def write_long(data)
  write(pack_long(data))
end

Size and data can have different encoding Marshal: both ASCII Oj: ASCII and UTF-8

# File 'lib/spark/ext/io.rb', line 47

def write_string(data)
  write_int(data.bytesize)
  write(data)
end