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