前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >2021年最新最全Flink系列教程__Flink综合案例(九)

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

作者头像
Maynor
发布2021-12-07 10:28:33
2510
发布2021-12-07 10:28:33
举报

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 服务启动
本文参与 腾讯云自媒体分享计划,分享自作者个人站点/博客。
原始发表:2021-07-09 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • day09_综合案例
    • 今日目标
      • Flink FileSink 落地写入到 HDFS
        • FlinkSQL 整合 Hive
          • Flink实现订单自动好评
            • 问题
            相关产品与服务
            大数据
            全栈大数据产品,面向海量数据场景,帮助您 “智理无数,心中有数”!
            领券
            问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档