Ошибка при чтении Скучный сжатый файл

Question

Я читаю Snappy Compressed file от местного до java.

File snappyFile = new File(fileName); 
Configuration conf = new Configuration();    
CompressionCodec codec = (CompressionCodec) 
ReflectionUtils.newInstance(SnappyCodec.class, conf); 
FileInputStream is2 = new FileInputStream(snappyFile); 
CompressionInputStream cis = codec.createInputStream(is2); 
BufferedReader cr = new BufferedReader(new InputStreamReader(cis)); 

Мой код получает исключение в ReflectionUtils.newInstance

Exception in thread "main" java.lang.RuntimeException: java.lang.NoSuchMethodException: org.xerial.snappy.SnappyCodec.<init>() 
    at org.apache.hadoop.util.ReflectionUtils.newInstance(ReflectionUtils.java:128) 
    at org.finra.oats.AWS.AWSnappyRead.run(AWSnappyRead.java:64) 
    at org.finra.oats.AWS.AWSnappyRead.main(AWSnappyRead.java:48) 
Caused by: java.lang.NoSuchMethodException: org.xerial.snappy.SnappyCodec.<init>() 
    at java.lang.Class.getConstructor0(Class.java:2849) 
    at java.lang.Class.getDeclaredConstructor(Class.java:2053) 
    at org.apache.hadoop.util.ReflectionUtils.newInstance(ReflectionUtils.java:122) 
    ... 2 more 

Является ли это из-за версии проблемы несоответствия. Я использую snappy 1.1.1.2 версия

Answer 1

Чтобы прочитать и записать сжатый файл Snappy, вы можете использовать предоставленные классы /SnappyOutputStream.

String fileName = "foo.snap"; 

// write a snappy compressed file 
try (OutputStream os = new SnappyOutputStream(new FileOutputStream(fileName))) { 
    os.write("Hello Snappy-World".getBytes(Charset.defaultCharset())); 
} 

// read a snappy compressed file 
try (InputStream is = new SnappyInputStream(new FileInputStream(fileName))) { 
    byte[] bytes = new byte[100]; 
    is.read(bytes); 
    System.out.println(new String(bytes, Charset.defaultCharset())); 
} 

// check if the file is compressed with the snappy algorithm 
try (InputStream is = new FileInputStream(fileName)) { 
    SnappyCodec readHeader = SnappyCodec.readHeader(is); 
    if (readHeader.isValidMagicHeader()) { 
     System.out.println("is a Snappy compressed file"); 
     System.out.printf("%s: %d%n%s: %d%n", 
       "compatible version", readHeader.compatibleVersion, 
       "version", readHeader.version 
     ); 
    } else { 
     System.out.println("is not a Snappy compressed file");     
    } 
}