在hadoop程序中,我尝试压缩结果,我编写了以下代码:
FileOutputFormat.setCompressOutput(job, true);
FileOutputFormat.setOutputCompressorClass(job, GzipCodec.class);
结果被压缩了,当我删除第一行时:
FileOutputFormat.setCompressOutput(job, true);
再执行一次程序,结果是一样的,就是上面的代码
fileoutputformat.setcompressoutput(job,true);
可选?那代码的作用是什么?
1条答案
按热度按时间o7jaxewo1#
请参阅fileoutputformat.java中的以下方法,它在内部调用已删除的方法调用。
i、 e setcompressoutput(conf,true);
这意味着您正在尝试应用gzip codec类,然后很明显它是一个指向应该压缩输出的代码的指针。不是吗?