2023-04 04-18 Flink新版kafka连接器的KafkaSource与KafkaSink的使用示例 2022-03 03-09 在Stream流中使用partitioningBy根据条件对集合中的元素进行分组 2021-12 12-08 scala通过反射实现Map与case class(案例类)相互转化 12-07 scala实现try-with-resources自动关闭IO 12-07 在scalikejdbc中使用动态表名 12-07 使用scalikejdbc的进行BatchUpdate(批量插入、更新) 12-07 设置HikariCP作为scalikejdbc连接池 2021-08 08-31 使用Stream流对List中的Map进行多条件去重 08-17 在flink中使用broadcast(广播流)实现配置动态加载 08-17 使用Streaming File Sink写入hdfs时自定义分桶策略
