flink-sql-hdfs-connector
支持根据数据的事件时间落到对应的分区目录
分支说明
master分支不放代码,分支对应适应相同版本的flink,例如分支flink-1.10就仅在flink 1.10版本上测试通过
使用方法
下载代码编译
cd flink-sql-hdfs-connector
mvn clean package
ll target/flink-sql-hdfs-connector-1.10-shaded.jar
复制target / flink-sql-hdfs