Module: Avromatic::Model::RawSerialization::ClassMethods
- Includes:
- Decode
- Defined in:
- lib/avromatic/model/raw_serialization.rb
Instance Method Summary collapse
- #datum_reader ⇒ Object
- #datum_reader_class ⇒ Object
- #datum_writer ⇒ Object
- #datum_writer_class ⇒ Object
Methods included from Decode
Instance Method Details
#datum_reader ⇒ Object
116 117 118 119 120 121 122 |
# File 'lib/avromatic/model/raw_serialization.rb', line 116 def datum_reader @datum_reader ||= begin hash = { value: datum_reader_class.new(value_avro_schema) } hash[:key] = datum_reader_class.new(key_avro_schema) if key_avro_schema hash end end |
#datum_reader_class ⇒ Object
100 101 102 |
# File 'lib/avromatic/model/raw_serialization.rb', line 100 def datum_reader_class Avromatic.use_custom_datum_reader ? Avromatic::IO::DatumReader : Avro::IO::DatumReader end |
#datum_writer ⇒ Object
108 109 110 111 112 113 114 |
# File 'lib/avromatic/model/raw_serialization.rb', line 108 def datum_writer @datum_writer ||= begin hash = { value: datum_writer_class.new(value_avro_schema) } hash[:key] = datum_writer_class.new(key_avro_schema) if key_avro_schema hash end end |
#datum_writer_class ⇒ Object
104 105 106 |
# File 'lib/avromatic/model/raw_serialization.rb', line 104 def datum_writer_class Avromatic.use_custom_datum_writer ? Avromatic::IO::DatumWriter : Avro::IO::DatumWriter end |