使用spark streaming使用snappy压缩保存数据到HDFS中

工做中须要将从Kafka中的数据保存到HDFS中去,而且须要使用snappy压缩java 话很少说,直接上代码apache /** * 自定义多目录写与追加写,采用snappy压缩 * @author demon * @version 2019/05/05 */ class AppendTextOutputFormat extends TextOutputFormat[Any, A
相关文章
相关标签/搜索