чтение snappy файла в Java Map уменьшить

Question

Можем ли мы использовать мгновенный файл в качестве входного файла для приложения «Уменьшить карту» без использования пользовательского класса ввода?

Я не был в состоянии найти информацию об этом.

С уважением, Ниш

Answer 1

Да, вы можете сделать это, но вы, возможно, придется распаковать файл первым, чтобы использовать его.

CompressionCodec codec = (CompressionCodec) ReflectionUtils.newInstance(SnappyCodec.class, new Configuration()); 

После создания экземпляра кодека вызовите createInputStream и передайте путь hadoop. codec.createInputStream