MapReduce想通过Hbase传递多个列族给reducer,如何实现

MapReduce通过HBase传递多个列族给Reducer可以使用以下步骤实现：

1. 在MapReduce中，使用TableMapReduceUtil.initTableMapperJob()初始化HBase表的Mapper作业。

2. 在Mapper类中，使用TableMapReduceUtil.initTableReducerJob()初始化HBase表的Reducer作业，并设置多个列族。

3. 在Reducer类中，使用TableOutputFormat.setOutput()设置输出表的列族。

例如，以下代码片段演示了如何通过HBase传递多个列族给reducer：

TableMapReduceUtil.initTableMapperJob(
    "table_name",
    scan,
    Mapper.class,
    ImmutableBytesWritable.class,
    Result.class,
    job
);

TableMapReduceUtil.initTableReducerJob(
    "output_table_name",
    Reducer.class,
    job,
    null,
    null,
    null,
    new String[] { "column_family1", "column_family2" }
);

job.setOutputFormatClass(TableOutputFormat.class);
TableOutputFormat.setOutput(job, "output_table_name");

在这个例子中，Reducer类将处理两个列族："column_family1"和"column_family2"。在初始化Reducer作业时，这两个列族被传递给了TableMapReduceUtil.initTableReducerJob()方法。在Reducer类中，使用TableOutputFormat.setOutput()方法设置输出表的列族。

通过这种方式，您可以轻松地将多个列族传递给HBase中的Reducer作业。