2021年最新最全Flink系列教程__Flink综合案例(九)

day09_综合案例

今日目标

• Flink FileSink 落地写入到 HDFS
• FlinkSQL 整合 Hive数据仓库
• 订单自动好评综合案例

Flink FileSink 落地写入到 HDFS

FlinkSQL 整合 Hive

Flink实现订单自动好评

问题

• Streaming File sink 落地到 HDFS 上， 无法正常写入到 HDFS
  1. 导入依赖，确定是否有问题
  2. 确定 hdfs 服务启动

代码语言：javascript复制

();
 }
 }
 //在生产环境下，可以去查询相关的订单系统.
 //模拟给 orderId 随机给是否已经点评，如果被2整除，已经点评过了，否则还没有点评
 private boolean isEvaluation(String key) {
 return key.hashCode() % 2 == 0;//随机返回订单是否已评价
 }
 }
 }

代码语言：javascript复制

## 问题

  Streaming File sink 落地到 HDFS 上， 无法正常写入到 HDFS
1. 导入依赖，确定是否有问题
2. 确定 hdfs 服务启动

flink sql hive 大数据 node.js

0 人点赞