Flink_StreamingFileSink-实时数据写入HDFS
Flink DataStream中将流数据保存HDFS文件系统方式:
第一种方式:自定义Sink,实现RichSinkFunction
使用JDBC的方式将数据写入到Hive数据库中,这种方式效率比较低
原因在于:INSERT INTO 插入数据,底层运行MapReduce程序,所以不推荐使用,了解即可。
第二种方式:StreamingFileSink Connector
流式写入H