IMF spark 读入文件中文编码转换处理（JAVA版本）

IMF spark 读入文件中文编码转换处理（JAVA版本）

SparkConf sparkConf = new SparkConf().setMaster("local").setAppName("UTFtoGBK");
JavaSparkContext sc = new JavaSparkContext(sparkConf);
JavaRDD lines = sc.hadoopFile("G://path//test.log", TextInputFormat.class, LongWritable.class, Text.class, 4)
        .map(new Function