spark开发笔记-scala 读写lzo文件两种写法
方法一:
val files = sc.newAPIHadoopFile("s3n://<YOUR_BUCKET>/<YOUR_PATH_TO_LZO_FILES/*.lzo", classOf[com.hadoop.mapreduce.LzoTextInputFormat],val spark开发笔记-scala 读写lzo文件两种写法
方法一:
val files = sc.newAPIHadoopFile("s3n://<YOUR_BUCKET>/<YOUR_PATH_TO_LZO_FILES/*.lzo", classOf[com.hadoop.mapreduce.LzoTextInputFormat],val