每个HBase表有一个Reducer

基本上,我需要将数据路由到正确的减速器。每个减速机都将是一个表减速机。

我有以下文件

venodor1,user1,xxxx=n venodor1,user1,xxxx=n venodor2,user2,xxxx=n

[用户1]=>{data:xxxx = n} [用户2]=>{data:xxxx = n}

[用户1]=>{data:xxxx = n}

格式为[行ID]=>{[族]:[COLUMN]=[VALUE]}

• 每个供应商都有不同的hbase表
• 行需要根据行中的值转到不同的hbase表。

谢谢, 费德里科