现在有一个业务需求,要使用storm的drpc,首先,有两张表,一张在mysql中,叫分类表,有商品分类id,和分类名称。还有一张表叫订单表(hbase中),上面有商品名称,和商品的分类id,现在需要对这个订单数据进行分类,需要输出分类名称,和商品名称,怎么用storm的drpc实现
另外一张在hbase中
订单表因为数量大,所以用hbase存储了
也就是说现在有两个流,一个是从hbase中读取的流数据,一个从mysql中读取的流数据,要怎么把数据关联起来,
相当于在mysql中的 inner Join操作,怎么实?可以详细回答吗?