如何实现Flink实时项目中订单维度表的关联操作？

本文共计5926个文字，预计阅读时间需要24分钟。

在上一篇文章中，我们已将订单和订单明细表通过join关联，本文将关联订单的其他维度数据。实际上，这些维度数据在HBase中存储。由于HBase的查询速度较快，我们直接通过主键的方式查询。

在上一篇中，我们已经把订单和订单明细表join完，本文将关联订单的其他维度数据，维度关联实际上就是在流中查询存储在 hbase 中的数据表。但是即使通过主键的方式查询，hbase 速度的查询也是不及流之间的 join。外部数据源的查询常常是流式计算的性能瓶颈，所以我们在查询hbase维度数据的基础上做一些优化及封装。 1. 维度查询

在上一篇中，我们已经把订单和订单明细表join完，本文将关联订单的其他维度数据，维度关联实际上就是在流中查询存储在 hbase 中的数据表。但是即使通过主键的方式查询，hbase 速度的查询也是不及流之间的 join。外部数据源的查询常常是流式计算的性能瓶颈，所以我们在查询hbase维度数据的基础上做一些优化及封装。

phoenix查询封装

phoenix作为hbase的一个上层sql封装，或者叫做皮肤，可以使用标准的sql语法来使用hbase，我们做一些简单的查询hbase的工具类。