spark讀取lzo文件並指定日誌記錄起始標識符

1、讀取文件是LzoTextInputFormat.class 2、設置 JavaSparkContext jsc = new JavaSparkContext(conf); Configuration hconf = jsc.hadoopConfiguration(); hconf.set("textinputformat.record.delimiter", "[*&^%]");      h

>>阅读原文<<