写文章
- @u010259977
简介
该用户还未填写简介
擅长的技术栈
未填写擅长的技术栈
可提供的服务
暂无可提供的服务
linux上的Tomcat 8 的远端debug调试
tomcat的debug远端调试
Flink的StreamingFileSink自定义DateTimeBucket
用flink消费kafka内容，通过清洗、转换、过滤后，要sink到parquet文件，需要按照事件的event进行分区生产需要写入的文件夹，如event1的发生时间在2018-03-19，而event2的发生时间在2018-03-20，这就涉及到extract它的eventtime，并生产parquet文件的bucktId,具体代码如下：/** Licensed to the A...
到底了