java - hadoop hbase mapreduce 组合器

Question

现在我正在编写一个 Java 程序来使用 Hadoop MapReduce 将输出写入 HBase。问题是关于Combiner 类的。因为现在我的 reduce 类扩展了 TableReducer，而不是 Reducer。那么我的组合器类呢，它应该也扩展 TableReducer，还是仍然扩展 Reducer？

Answer 1

您的组合器类应该扩展 TableReducer 本身而不是 Reducer。