Module: AvroPatches::SchemaValidator::IOPatches

Defined in:
lib/avro-patches/schema_validator/io.rb

Instance Method Summary collapse

Instance Method Details

#write_array(writers_schema, datum, encoder) ⇒ Object

Raises:

  • (Avro::IO::AvroTypeError) 


37
38
39
40
 
# File 'lib/avro-patches/schema_validator/io.rb', line 37

def write_array(writers_schema, datum, encoder)
  raise Avro::IO::AvroTypeError.new(writers_schema, datum) unless datum.is_a?(Array)
  super
end

#write_map(writers_schema, datum, encoder) ⇒ Object

Raises:

  • (Avro::IO::AvroTypeError) 


42
43
44
45
 
# File 'lib/avro-patches/schema_validator/io.rb', line 42

def write_map(writers_schema, datum, encoder)
  raise Avro::IO::AvroTypeError.new(writers_schema, datum) unless datum.is_a?(Hash)
  super
end

#write_record(writers_schema, datum, encoder) ⇒ Object

Raises:

  • (Avro::IO::AvroTypeError) 


32
33
34
35
 
# File 'lib/avro-patches/schema_validator/io.rb', line 32

def write_record(writers_schema, datum, encoder)
  raise Avro::IO::AvroTypeError.new(writers_schema, datum) unless datum.is_a?(Hash)
  super
end