java (6123) mysql (4376) big data (1849) oracle (1369) spring (1288) 大数据 (566) spring boot (136) springboot (133) flink (29) springmvc (14)
Flink新版kafka连接器的KafkaSource与KafkaSink的使用示例
开发过程中，有时会遇到需要根据某些条件对集合中的元素进行分组
遇到个需求，需要将Map转换为case class以及将case class转换回Map的场景，之前写java的时候会使用BeanUtil之类的工具类实现，但这些工具类到scala中遇到case class有些水土不服，不能正常使用，无奈之下只能自己写个工具，通过反射实现这两个的转换Map转换为ca