请稍等 ...
×

采纳答案成功!

向帮助你的同学说点啥吧!感谢那些助人为乐的人

一个很重要业务上的问题?

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

正在回答 回答被采纳积分+3

1回答

Michael_PK 2018-12-12 16:52:41

数据在MySQL和HBase里面,那么需要storm的Spout接收的是什么样的新tuple?

0 回复 有任何疑惑可以回复我~
  • 提问者 慕仙4974986 #1
    可定时jdbc一个Spout,Hbase一个Spout了,或者说,你可以把两个结合吗?
    回复 有任何疑惑可以回复我~ 2018-12-12 16:56:12
  • Michael_PK 回复 提问者 慕仙4974986 #2
    定时了,那直接批处理就搞定了。
    回复 有任何疑惑可以回复我~ 2018-12-12 17:00:27
  • 提问者 慕仙4974986 回复 Michael_PK #3
    没有明白
    回复 有任何疑惑可以回复我~ 2018-12-12 17:16:58
问题已解决,确定采纳
还有疑问,暂不采纳
意见反馈 帮助中心 APP下载
官方微信