test/test_datafile.rb in avro-1.7.7 vs test/test_datafile.rb in avro-1.8.0
- old
+ new
@@ -165,10 +165,23 @@
reader.each {|record| records << record }
end
assert_equal records, ['a' * 10_000]
end
+ def test_snappy
+ Avro::DataFile.open('data.avr', 'w', '"string"', :snappy) do |writer|
+ writer << 'a' * 10_000
+ end
+ assert(File.size('data.avr') < 600)
+
+ records = []
+ Avro::DataFile.open('data.avr') do |reader|
+ reader.each {|record| records << record }
+ end
+ assert_equal records, ['a' * 10_000]
+ end
+
def test_append_to_deflated_file
schema = Avro::Schema.parse('"string"')
writer = Avro::IO::DatumWriter.new(schema)
file = Avro::DataFile::Writer.new(File.open('data.avr', 'wb'), writer, schema, :deflate)
file << 'a' * 10_000
@@ -182,7 +195,20 @@
records = []
Avro::DataFile.open('data.avr') do |reader|
reader.each {|record| records << record }
end
assert_equal records, ['a' * 10_000, 'b' * 10_000]
+ end
+
+ def test_custom_meta
+ meta = { 'x.greeting' => 'yo' }
+
+ schema = Avro::Schema.parse('"string"')
+ writer = Avro::IO::DatumWriter.new(schema)
+ file = Avro::DataFile::Writer.new(File.open('data.avr', 'wb'), writer, schema, nil, meta)
+ file.close
+
+ Avro::DataFile.open('data.avr') do |reader|
+ assert_equal 'yo', reader.meta['x.greeting']
+ end
end
end