文件名称:flink-sql-hdfs-connector:支持根据数据的事件时间落到对应的分区目录
文件大小:5KB
文件格式:ZIP
更新时间:2024-04-07 04:19:29
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-connector-1.10-shaded.jar到flink安装目录的lib下即可使用 sql样例 CREATE TABLE hdfs_file_sink ( ` id ` bigint , ` policy_id ` INT , ` policy_no `
【文件预览】:
flink-sql-hdfs-connector-main
----LICENSE(11KB)
----README.md(1KB)