spark读取lzo文件并指定日志记录起始标识符

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

>>阅读原文<<