pom配置
<dependency>
<groupId>org.anarres.lzo</groupId>
<artifactId>lzo-hadoop</artifactId>
<version>${lzo.version}</version>
</dependency>
Lzo配置
Configuration configuration = new Configuration();
configuration.set("io.compression.codecs", "com.hadoop.compression.lzo.LzoCodec");
configuration.set("fs.defaultFS","");
Java代碼
LzopCodec lzo = null;
try {
lzo = new LzopCodec();
lzo.setConf(HDFSUtils.getLzoDefaultConf()); //為Lzo配置項(xiàng)
is = lzo.createInputStream(fs.open(lzoFilePath)); // fs為FileSystem對象
isr = new InputStreamReader(is);
reader = new BufferedReader(isr);
while ((line = reader.readLine()) != null) {
// Process
}
}
最后編輯于 ：
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
