2013-11-15 5 views

ответ

1

решаемые его:

require 'avro' 

def open_avro(file) 
    if file =~ /avro$/ 
    Avro::DataFile.open(file) 
    elsif file =~ /avro\.gz$/ 
    begin 
     $/ = "" 
     file = Zlib::GzipReader.open(file) 
     reader = Avro::IO::DatumReader.new(file, nil) 
     file.rewind # we need to rewind because DatumReader seeked thefile 
     avro = Avro::DataFile::Reader.new(StringIO.new(file.gets), reader) 
    end 
    return avro 
    end 
end 
Смежные вопросы