flink-sql-hdfs-connector:支持根据数据的事件时间落到对应的分区目录

时间:2024-04-07 04:19:29
【文件属性】:

文件名称: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)

网友评论

  • 假的,没有用处