Class: RFlow::Avro

Inherits:

Object

• Object
• RFlow::Avro

Defined in:

lib/rflow/message.rb

Overview

Utility methods for doing Avro encoding/decoding.

Class Method Summary

• .decode(reader, bytes) ⇒ Object

  Decode serialized Avro data.

• .encode(writer, message) ⇒ String

  Encode data to serialized Avro.

Class Method Details

.decode(reader, bytes) ⇒ Object

Decode serialized Avro data.

Parameters:

• reader (::Avro::IO::DatumReader) —

  reader preconfigured with schema

• bytes (String) —

  byte string to decode

Returns:

• decoded object

# File 'lib/rflow/message.rb', line 17

def self.decode(reader, bytes)
  reader.read ::Avro::IO::BinaryDecoder.new(StringIO.new(bytes.force_encoding('BINARY')))
end

.encode(writer, message) ⇒ String

Encode data to serialized Avro.

Parameters:

• writer (::Avro::IO::DatumWriter) —

  writer preconfigured with schema

• message (String)

Returns:

• (String)

# File 'lib/rflow/message.rb', line 25

def self.encode(writer, message)
  String.new.force_encoding('BINARY').tap do |result|
    writer.write message, ::Avro::IO::BinaryEncoder.new(StringIO.new(result, 'w'))
  end
end