工程里加 POM 依赖:
- flink table planner
- flink connector files
- flink json
- hadoop client
~~~~~~~~~~~
教程里的版本是 1.15
演示的代码是3个 sql ,创建 2个表,执行 insert 语句:
file_source 数据来源(json 文件)
print_sink 结果打印到控制台 (print 控制台)
先启动 hdfs 集群,才能在 file_source 调用 hdfs://bigdata01:9000/stu.json )
对比 stream 模式 和 batch 模式 , steam 是一条条记录产生,而 batch是全部记录一次产生(离线模式)