开发者社区> 问答> 正文

spark DataFrame写入HDFS是怎么压缩的?

spark DataFrame写入HDFS是怎么压缩的?

展开
收起
芯在这 2021-12-08 17:42:22 702 0
1 条回答
写回答
取消 提交回答
  • (1) spark textFile加载多个目录: 其实很简单,将多个目录(对应多个字符串),用,作为分隔符连接起来 val inputPath = List("hdfs://localhost:9000/test/hiveTest", "hdfs://localhost:9000/test/hiveTest2") .mkString(",") sparkContext .textFile( inputPath )

    (2) spark rdd saveAsTextFile 输出到HDFS 文件压缩 rdd.saveAsTextFile( "hdfs://localhost:9000/test/out" ) //正常不压缩 rdd.saveAsTextFile( "hdfs://localhost:9000/test/outGzip", classOf[ GzipCodec ] ) //Gzip压缩输出 rdd.saveAsTextFile( "hdfs://localhost:9000/test/outBzip2", classOf[ BZip2Codec ] ) //bzip2 压缩输出

    2021-12-08 17:43:08
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Apache Spark: Cloud and On-Prem 立即下载
Hybrid Cloud and Apache Spark 立即下载
海量数据分布式存储——Apache HDFS之最新进展 立即下载