Spark平臺中,對lzo壓縮文件的讀取--Scala實現

#記錄一個坑# 在Spark中,有時須要對lzo壓縮文件的讀取。這裏採用的是newAPIHadoopFile()來進行讀取 val configuration = new Configuration() configuration.set("io.compression.codecs", "org.apache.hadoop.io.compress.DefaultCodec,org.apa
相關文章
相關標籤/搜索