使用Flink处理Kafka中的数据_题库子任务7、8、9_Java语言实现
注：与订单金额计算相关使用order_money字段，同一个订单无需多次重复计算，需要考虑退款或者取消的订单。
编写Java代码，使用Flink消费Kafka中Topic为ods_mall_log和ods_mall_data的数据并进行相应的数据统计计算(使用ProcessTime）。
点击正文链接，可快速跳转到相应子任务实现部分：
子任务7
子任务7描述
7、使用Flink消费Kafka的dwd层数据，监控order_status字段为已退款的数据,将数据存入ClickHouse数据库shtd_result的order_master表中，然后在Linux的ClickHouse命令行中根查询出前5条。
实现原理
这个任务涉及到一个新的大数组组件ClickHouse，需要使用flink-clickhouse连接器。关于ClickHouse的基本用法，可参考小白学苑教程：会员登录