我在hdfs中使用gzip压缩来压缩数据。在从同一个uri读回数据时,我使用compressioncodecfactory,它动态地找出正在使用的压缩器的类型并检索结果。不知何故compressioncodecfactory无法读取gzip压缩并返回null。
Configuration conf = new Configuration();
CompressionCodecFactory factory = new CompressionCodecFactory(conf);
CompressionCodec cdc = factory.getCodec(new Path(path));
根据文档,它应该动态地获取所用压缩机的类型,并以某种方式将null返回给我。
暂无答案!
目前还没有任何答案,快来回答吧!