本项目为flink练手项目,主要为熟悉flink的基本操作&使用.
代码位置: src/main/scala/com/boyi/datasource
代码位置: src/main/scala/com/boyi/transform
代码位置: src/main/scala/com/boyi/other
代码位置: src/main/scala/com/boyi/sink
本项目为flink练手项目,主要为熟悉flink的基本操作&使用.
代码位置: src/main/scala/com/boyi/datasource
代码位置: src/main/scala/com/boyi/transform
代码位置: src/main/scala/com/boyi/other
代码位置: src/main/scala/com/boyi/sink